Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

kafka 0.11 reset offset for consumer group by --to-datetime

Kafka consumer offsets out of range with no configured reset policy for partitions

Kafka-consumer. commitSync vs commitAsync

Limit Kafka batches size when using Spark Streaming