apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How does Kafka Streams work with Partitions that contain incomplete Data?
user_26207160
•
7
1
2911
apache-kafka-streams apache-kafka
Kafka Rebalancing. Duplicate processing issue
user_10481850
•
14
2
8605
kafka-consumer-api apache-kafka java
what is best practice to consume messages from multiple kafka topics?
user_62077690
•
6
2
7922
kafka-consumer-api apache-kafka multithreading
Consume kafka messages from django app
user_12814700
•
11
1
2909
apache-kafka celery django
Kafka streams filtering: broker or consumer side?
user_5082190
•
2
2
6270
apache-kafka-streams kafka-consumer-api apache-kafka
Spark Streaming from Kafka topic throws offset out of range with no option to restart the stream
user_31126720
•
3
4
6826
spark-streaming apache-kafka apache-spark scala
kafka producers are very slow
user_87320640
•
6
1
12009
kafka-producer-api apache-kafka java
Kafka Connect - Cannot ALTER to add missing field SinkRecordField{schema=Schema{BYTES}, name='CreateUID', isPrimaryKey=true},
user_59433440
•
3
1
2523
apache-kafka-connect apache-kafka
RecordTooLargeException in Kafka streams join
user_13068190
•
9
1
11284
apache-kafka-streams apache-kafka java
How to finish kafka consumer safety?(Is there meaning to call thread#join inside shutdownHook ? )
user_26743030
•
3
1
5094
kafka-consumer-api apache-kafka shutdown-hook multithreading java
Hot Questions