apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
kafka 0.11 reset offset for consumer group by --to-datetime
user_11135420
•
20
3
17773
kafka-consumer-api apache-kafka
Flink with Confluent Kafka schema registry
user_43308180
•
4
2
3849
confluent-schema-registry apache-flink apache-kafka avro
How to setup kafka transactional producer
user_62049580
•
5
0
5435
kafka-producer-api spring-kafka apache-kafka java
Kafka producer send blocks indefinitely when kafka servers are down
user_50296270
•
7
2
6832
kafka-producer-api apache-kafka
How can you set the max.message.bytes of a state store changelog topic?
user_1168500
•
3
1
3939
apache-kafka-streams apache-kafka
How to query Kafka topic for records in a partition with timestamp inside interval?
user_2735940
•
4
0
666
apache-kafka
Spring Kafka: Poll for new messages instead of being notified using `onMessage`
user_9475260
•
3
2
5111
spring-kafka kafka-consumer-api apache-kafka spring
Kafka partition Lag increasing
user_32734180
•
3
2
14201
kafka-python kafka-consumer-api apache-kafka python
What's the different between ctrl-c and kill -9 when making kafka broker down
user_73572970
•
3
2
2157
apache-kafka failover
Expiring 1 record(s) for xxxxx: 30030 ms has passed since batch creation plus linger time
user_5880180
•
6
1
7770
kafka-producer-api apache-kafka docker java
Hot Questions