apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
spring kafka, how to gracefully shutdown the spring boot application
user_58286210
•
2
0
1223
spring-kafka-test spring-kafka apache-kafka spring-boot spring
How to start @KafkaListener based on start flag
user_83837440
•
3
2
3063
apache-kafka java
spark writeStream into kafka - Difference between awaitTermination() vs awaitAnyTermination()
user_74866210
•
3
1
946
spark-structured-streaming pyspark apache-kafka apache-spark
ElasticsearchSinkConnector object mapping can't be changed from nested to non-nested
user_58629540
•
2
2
825
apache-kafka-connect elasticsearch apache-kafka java
How to produce Kafka messages with JSON format in Python
user_129586570
•
3
1
7159
kafka-python kafka-producer-api apache-kafka python
Trying to pass binary files through Logstash
user_43407930
•
3
2
590
logstash apache-kafka amazon-s3
How to write KTable in a Kafka topic? Like we use "to()" in KStreams how to do that for KTable?
user_100110500
•
2
2
1558
ktable spring-kafka apache-kafka-streams apache-kafka
On the Kafka Java consumer client, is there a way to monitor health status as opposed to simply no-data?
user_2365280
•
8
1
296
kafka-consumer-api apache-kafka java
Healthcheck not working at all when using docker-compose (My service do not wait for Kafka to be started before launching)
user_136496490
•
2
1
3831
docker-compose apache-kafka docker java
How do I get child process PIDs when using ProcessPoolExecuter?
user_43808530
•
5
2
1890
apache-kafka python
Hot Questions