Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

How to finish kafka consumer safety?(Is there meaning to call thread#join inside shutdownHook ? )

Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode

kafka partition rebalancing (assignment) is taking too much time

Spring boot Kafka Consumer Bootstrap Servers always picking Localhost 9092

Spring Boot Manual Acknowledgement of kafka messages is not working

Bucket records based on time(kafka-hdfs-connector)

Does ConcurrentKafkaListenerContainerFactory increases parallelism in consumption of messages from Kafka Topics

Kafka error handling and deadletter queues

Kafka consumer rebalancing condition

Consume from timestamp using offsets_for_times

Apache Kafka: Exactly Once in Version 0.10

Delete __Consumer_offset Topic form Kafka

Spring Kafka: Poll for new messages instead of being notified using `onMessage`

Alternate for polling Kafka server

Get latest values from a topic on consumer start, then continue normally

Kafka increasing processing timeout message

My Kafka consumer retry for 10 times abnormally, and stop its retrying by simply adding a MDC log?

How to consume from Kafka topic in multiple goroutines, using Sarama?

How to send Kafka message from one topic to another topic?