Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

How does (should) Kafka Consumer cope with Poison Messages

apache- kafka with 100 millions of topics

How to find which consumer is assigned to which partition of a topic in kafka?

Conditions in which Kafka Consumer (Group) triggers a rebalance

Kafka Consumer seektoBeginning

How to stop Python Kafka Consumer in program?