Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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?

how to get acknowledgement from Kafka broker if message is produced by producer?

Kafka CommitFailedException consumer exception

Kafka streams.allMetadata() method returns empty list