apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
log4j properties BurstFilter configuration
user_109719170
•
2
1
787
apache-kafka log4j logging java
Is there a way to reset offsets of a Kafka consumer group through an API?
user_153516120
•
2
3
3184
spring-kafka apache-kafka spring-boot spring java
Using my trusted certificate in Kafka Strimzi
user_116001090
•
1
1
1605
strimzi apache-kafka kubernetes ssl
Consumer does not read messages from the Kafka topic (Akka Stream Kafka)
user_33533880
•
1
1
512
kafka-transactions-api akka-stream apache-kafka java-8 java
Cygnus: Unable to deliver event. close() called when transaction is OPEN - you must either commit or rollback first
user_41739120
•
1
1
199
fiware-cygnus fiware apache-kafka
Will kafka delete the committed offset or compact it if offsets.retention.minutes=2 and cleanup.policy=compact
user_83448600
•
2
1
546
apache-kafka
Flink 1.11 FlinkKafkaConsumer fails to propagate watermarks while Flink 1.12 succeeds
user_2419100
•
1
1
190
apache-flink apache-kafka java
What consumer offset will be set if auto.offset.reset=earliest but topic has no messages
user_83448600
•
6
2
1276
kafka-consumer-api apache-kafka
Unable to use kafka mirror maker due to No serviceName defined in either JAAS or Kafka config
user_51960390
•
2
0
378
apache-kafka
Is there any method to retry within maxAttempts times using Acknowledge.nack for spring-cloud-stream-binder-kafka?
user_156230520
•
2
1
483
spring-cloud-stream-binder-kafka spring-cloud-stream apache-kafka spring java
Hot Questions