Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Kafka topic constantly rolling new log segments, no overrides, logfiles tiny

Randomly generated group id for Kafka Consumer

How to read from specific Kafka partition in Spark structured streaming

Create consumer dynamically spring kafka

Kafka Consumer - Point to specific offset in Spring boot Kafka

Kafka groups cleanup

Kafka Streams Threading Model with more than one Stream on the same instance and JVM

Kafka Consumer is not consuming messages from all partitions