apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
kafka-topics with bootstrap-server gives UnknownTopicOrPartitionException, but with zookeeper does not?
user_118951460
•
1
0
292
apache-kafka apache-zookeeper
How can I read every 5 seconds in pyspark with kafka readStream?
user_36728830
•
1
1
262
spark-structured-streaming pyspark apache-kafka apache-spark
Spring Kafka acknowledgment settings
user_178672720
•
3
2
654
spring-kafka apache-kafka spring-boot java
Throttling Kafka Messages to downstream service
user_179156850
•
1
0
139
spring-kafka apache-kafka spring
How do I write a big message into kafka with kafka producer API?
user_106818280
•
2
1
310
apache-kafka java
Structured Streaming runs out of memory after running for a while even with spark.catalog.clearCache()
user_126447550
•
1
0
252
spark-structured-streaming pyspark apache-kafka apache-spark
FLINK: Is it possible in the same flink job to read data from kafka topic (file names) and then read files content from amazon s3?
user_99043340
•
2
2
179
flink-streaming apache-flink apache-kafka amazon-s3
Spring Kafka Producer: receive inmediate error when broker is down
user_178969660
•
1
1
428
kafka-producer-api spring-kafka apache-kafka
Non-blocking retries with Spring Kafka batch consumer
user_117356640
•
2
1
491
spring-kafka apache-kafka spring-boot spring java
kafka: Connection to node 1001 could not be established. Broker may not be available
user_115232940
•
4
0
3479
apache-kafka docker
Hot Questions