Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Avro decoding gives java.io.EOFException

Kafka as a message queue for long running tasks

Kafka Maven Dependencies

Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Configure kafka-net to stop sending latest messages

kafka consumer group is rebalancing

List Kafka Topics via Spring-Kafka

Spring Boot Kafka Listener vs Consumer

Kafka-python get number of partitions for topic

Kafka multiple consumers for a partition

Kafka consumer - what's the relation of consumer processes and threads with topic partitions

Consuming from single kafka partition by multiple consumers

Spring Boot Kafka: Unable to start consumer due to NoSuchBeanDefinitionException

How to use Spring Kafka's Acknowledgement.acknowledge() method for manual commit

Kafka consumer "failed to find leader" when fetching topic metadata

Does commitOffsets on high-level consumer block?

Kafka Java API offset operations clarification

Kafka Offset after retention period