Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Should we use max.poll.records or max.poll.interval.ms to handle records that take longer to process in kafka consumer?

Enforce Unique consumer group id in Kafka

Kafka Java Consumer already closed

how to set kafka consumer concurrency using spring boot

Kafka stream vs kafka consumer how to make decision on what to use

How to gracefully shutdown spring-kafka consumer application