Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Kafka Consumer: No entry found for connection

Why do Kafka consumers output INVALID_FETCH_SESSION_EPOCH after updating to 1.1?

Kafka - Delayed Queue implementation using high level consumer

Kafka - difference between Log end offset(LEO) vs High Watermark(HW)

Kafka producer TimeoutException: Expiring 1 record(s)