Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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?

Asynchronous auto-commit of offsets fails

How to subscribe multiple topic using @KafkaListner annotation

Kafka topic is getting reappeared after 10 sec of deletion

Kafka Consumer Rebalancing and Its Impact

How to reinstate a Kafka Consumer which has been kicked out of the group?

How to write a Spark dataframe into Kinesis Stream?