Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Infinite retry in spring kafka consumer @retryabletopic

Kafka partition Lag increasing

EmbeddedKafka failed authentication due to: Unexpected handshake request with client mechanism PLAIN, enabled mechanisms are []

Kafka Consumer Leaving the Consumer Group

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