Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Fetching and Updating Kafka Topic Configurations through Java API

How to consume from latest offset using Sarama Go Kafka Consumer

In Kafka java api, what does the key and value of the concumerRecord mean?

Kafka Avro Console Consumer not working after enabling SSL encryption and authentication

Apache Kafka: ...StringDeserializer is not an instance of ...Deserializer

How to map types using properties file in Kafka

How to finish kafka consumer safety?(Is there meaning to call thread#join inside shutdownHook ? )

Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode

kafka partition rebalancing (assignment) is taking too much time

Spring boot Kafka Consumer Bootstrap Servers always picking Localhost 9092

Spring Boot Manual Acknowledgement of kafka messages is not working

Bucket records based on time(kafka-hdfs-connector)

Does ConcurrentKafkaListenerContainerFactory increases parallelism in consumption of messages from Kafka Topics

Kafka error handling and deadletter queues

Kafka consumer rebalancing condition