Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka - Consumer group creation with specific offset?

WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)

Kafka topic partition and Spark executor mapping

Error reading field 'topics': java.nio.BufferUnderflowException in Kafka

kafka-console-consumer custom deserializer

How does Zookeeper/Kafka retain offset for a consumer?

Kafka Consumer Assignment returns Empty Set

How to create a new consumer group in kafka

unable to set 'max.poll.records' under kafka consumer, where cons.poll still returns all records under partition

How customer offsets are maintained in mirrored cluster in Kafka?

How to pass multiple bootstrap servers for listener using spring-kafka

How does max.poll.records affect the consumer poll

Increase Kafka Streams Consumer Throughput

Prevent kafka consumer from timing out for long process

what is best practice to consume messages from multiple kafka topics?

Kafka Streams does not increment offset by 1 when producing to topic

How to consume data from kafka topic in specific offset to specific offset?

fetch.max.wait.ms vs parameter to poll() method

Kafka - What are the better alternatives than poll() to listen to a topic in Java?

How do I set the size of messages in Kafka?