Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Is Consumer Offset managed at Consumer group level or at the individual consumer inside that consumer group?

Load test kafka consumer

Infinite loop of Resetting offset and seeking for LATEST offset

get Kafka unconsumed messages count in Java