Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka consumer.poll returns no records

Kafka Acknowledgment vs Kafka commit

Kafka consumer does not start from latest message

Simple Kafka Consumer not receiving messages

Why is Kafka consumer ignoring my "earliest" directive in the auto.offset.reset parameter and thus not reading my topic from the absolute first event?

Kafka consumer group offset retention

module 'snappy' has no attribute 'decompress'

SBT cannot import Kafka encoder/decoder classes

kafka consumer to dynamically detect topics added

On the Kafka Java consumer client, is there a way to monitor health status as opposed to simply no-data?

Kafka consumer stuck in (Re-)joining group

Kafka Java consumer marked as dead for group

Message routing in kafka

How to get back Kafka producer and consumer configuration (Java API)?

How to authenticate/authorize a consumer in Kafka for a topic before it consumes the message