apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Is there a way to configure polling interval of @KafkaListener?
user_119606560
•
4
1
692
spring-kafka apache-kafka spring-boot
Spark Structured Streaming Kafka Headers property is null in ForEachWriter object
user_25594550
•
2
0
1180
spark-structured-streaming apache-kafka apache-spark java
Kafka Consumer not consuming reprocessed data with Spark
user_27026300
•
2
0
96
kafka-consumer-api apache-kafka apache-spark python
Difference between Spring's ConsumerSeekAware.onPartitionsAssigned and ConsumerAwareRebalanceListener.onPartitionsAssigned
user_14890080
•
2
0
145
apache-kafka spring
Can compacted Kafka topic be used as key-value database?
user_12593600
•
4
1
1510
kafka-topic apache-kafka
Disable mirrormaker2 offset-sync topics on source kafka cluster
user_70957510
•
8
1
1225
apache-kafka-mirrormaker apache-kafka-connect apache-kafka
How to implement "debouncing" for event-driven microservices?
user_146974150
•
2
1
233
microservices apache-kafka azure-functions kubernetes azure
When does Zookeeper change Kafka cluster ID?
user_17189840
•
2
1
3269
apache-kafka apache-zookeeper
Scala: Cannot resolve overloaded methods (Flink WatermarkStrategy)
user_77860160
•
4
2
1022
flink-streaming apache-flink apache-kafka
Does enabling Idempotence on a Kafka producer decrease throughput
user_38858190
•
5
1
6247
kafka-producer-api apache-kafka
Hot Questions