apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Why kafka consumer don't use jdk InterruptedException when poll()?
user_76762370
•
2
0
1061
kafka-consumer-api apache-kafka interrupted-exception java
Who keeps track of the last read message offset of the consumer in Apache Kafka?
user_110051750
•
3
1
1101
kafka-consumer-api apache-kafka
How to use kafka-node under typescript?
Admin1
•
4
2
2713
apache-kafka typescript node.js
Getting Multiple messages on spark-submit "seeking to EARLIEST and Resetting offset for partition topic-partition"
user_137425210
•
5
0
278
apache-kafka apache-spark
What is the optimal way to read from multiple Kafka topics and write to different sinks using Spark Structured Streaming?
user_96677210
•
9
2
1423
spark-structured-streaming pyspark apache-kafka apache-spark
Debezium issue with SQL Server
user_137349620
•
2
1
2050
debezium apache-kafka-connect apache-kafka docker sql-server
Provided Maven Coordinates must be in the form 'groupId:artifactId:version' PySpark and Kafka
user_44736150
•
2
1
1902
pyspark apache-kafka apache-spark
Kafka - Troubleshooting .NotEnoughReplicasException
user_42426750
•
2
1
5091
confluent-platform apache-kafka
Access TimeWindow properties inside an aggregator in Kafka Streams
user_67445110
•
2
1
45
apache-kafka-streams apache-kafka
Kafka - What does it mean by cluster-wide
user_42426750
•
2
1
702
confluent-platform apache-kafka
Hot Questions