Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Apache Kafka - Autocommit = false and no commit

Spring-Kafka cannot convert AVRO GenericData.Record to Acknowledgment

Spark-Streaming hangs with kafka starting offset at earliest (Kafka 2, spark 2.4.3)

Kafka design questions - Kafka Connect vs. own consumer/producer

Using multiple deserializers for a kafka consumer

How to make consume method as non blocking in confluent kafka for dot net

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