Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka Rebalancing. Duplicate processing issue

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

How to save latest offset that Spark consumed to ZK or Kafka and can read back after restart

Kafka bootstrap-servers vs zookeeper in kafka-console-consumer

Leader brokers without a matching listener error in kafka

Why does a Kafka consumer take a long time to start consuming?

Kafka Consumer - Poll behaviour

Difference between heartbeat.interval.ms and session.timeout.ms in Kafka consumer config

How to make kafka consumer to read from last consumed offset but not from beginning

Simple Kafka Consumer Example not working

Consume the same message again if processing of the message fails

How Kafka distributes the topic partitions among the brokers

How to use Consumer API of Kafka 0.8.2?

Consumer.poll() returns new records even without committing offsets?

kafka failed authentication due to: SSL handshake failed

Kafka consumer exception and offset commits

KafkaConsumer Java API subscribe() vs assign()

Is a web frontend producing directly to a Kafka broker a viable idea?

How to handle kafka publishing failure in robust way

How does Kafka Consumer Consume from Multiple assigned Partition