Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Consuming kafka batch for multiple partitions

How to send the data from Kafka to ElasticSearch using python

Limit the number of records Kafka consumer

Receiving Kafka Key in spring boot kafka listener

How Does Prometheus Scrape a Kafka Topic?

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