Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka not connecting getting below issue

Using Kafka's Log Compaction, what can I do to guarantee consumers don't miss messages, if they are not lagging behind by some defined timelimit?

How to implement ConsumerSeekAware in Spring-kafka?

How to configure Apache Kafka to sending data at specified time?

Kafka new consumer: (re)set and commit offsets with using assign, not subscribe

How to update Kafka consumer max.request.size config while using Spark structured stream

What is the ideal number of partitions in kafka topic?

Apache Kafka : commitSync after pause

Kafka Consumer is not reading the topic data through Java

How to consume/read messages from KAFKA topic with filter condition

How to parse json data which comes from kafka topic in Storm scheme class?

how to pause Kafka Consumer when I am using @KafkaListener Annotation

Duplicate message consumption in Kafka due to auto-downscaling/deletion of pods

Commiting offset after consumer error handling in spring-kafka