Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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)

Kafka console consumer ERROR "Offset commit failed on partition"

Counting Number of messages stored in a kafka topic

Kafka consumer offset max value?

Get last message from kafka consumer console script