Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-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

Consume from timestamp using offsets_for_times

Apache Kafka: Exactly Once in Version 0.10

Delete __Consumer_offset Topic form Kafka

Spring Kafka: Poll for new messages instead of being notified using `onMessage`