Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Kafka Consumers throwing java.lang.OutOfMemoryError: Direct buffer memory

Kafka not able to consume without reading from beginning -Java

kafka consumer seek is not working: AssertionError: Unassigned partition

Reading data from _transaction_state topic in Kafka 0.11.0.1

Spark structured streaming query always starts with auto.offset.rest=earliest even though auto.offset.reset=latest is set

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