Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

How to pass dynamic topic name to @KafkaListener(topics) from environment variable

Difference between poll and consume in Kafka Confluent library

Kafka keeps rebalancing consumers

Kafka throws java.nio.channels.ClosedChannelException

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