Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Return from Kafka consumer when there is no message

Flink+Kafka reset checkpoint and offset

What if a Kafka's consumer handles a message too long? Will Kafka reappoint this partition to another consumer and the message will doubly handled?

kafka MockConsumer throwing exception error java.lang.IllegalStateException: Subscription to topics, partitions and pattern are mutually exclusive

java kafka-consumer-api

Describe Kafka Consumer Groups Response

Kafka python Consumer group session timed out

python confluent kafka: Group authorization failed

Alpakka Consumer not consuming messages from Kafka running via Docker compose

Kafka Reduce Lag for Consumer

Kafka consume message in reverse order

How to Partial commitSync when consume batch in kafka

IllegalStateException Subscription to topics, partitions and pattern are mutually exclusive

Does Kafka support request response messaging

Kafka Consumer Error - xxxx nodename nor servname provided, or not known

kafka-node consumer receives offsetOutOfRange error

Kafka Consumer subscription vs. assigned partition

How to migrate consumer offsets using MirrorMaker 2.0?

Kafka in docker-compose: topics not in preferred replica for broker

How does Spring Kafka manual commit works in Batch listener mode

kafka consumer in shell script