kafka-consumer-api tutorials

How do I stop attempting to consume messages off of Kafka when at the end of the log?

Sep 04, 2022

apache-kafka kafka-consumer-api

Can a kafka consumer group freeze during a rebalance

Oct 31, 2022

apache-kafka kafka-consumer-api

Kafka having duplicate messages

Apr 14, 2022

apache-kafka kafka-consumer-api kafka-producer-api

Spark Streaming from Kafka Consumer

Oct 19, 2022

apache-spark apache-kafka pyspark spark-streaming kafka-consumer-api

Maximum subscription limit of Kafka Topics Per Consumer

Jun 28, 2022

apache-kafka kafka-consumer-api

Consumer and producer failing with error: "Connection to 0 was disconnected before the response was read"

Jul 18, 2022

apache-kafka apache-zookeeper kafka-consumer-api kafka-producer-api

What is the difference between MANUAL and MANUAL_IMMEDIATE in spring-kafka AckMode

Sep 05, 2022

apache-kafka kafka-consumer-api spring-kafka

Kafka: what is the point of using "acknowledgment.nack" if I can simply "not acknowledgment.acknowledge"

Sep 14, 2022

java apache-kafka spring-integration kafka-consumer-api spring-kafka

How to remove a Kafka consumer group from a specific topic?

Aug 26, 2022

apache-kafka kafka-consumer-api consumer

Kafka - Consumer group creation with specific offset?

Oct 23, 2022

java apache-zookeeper apache-kafka kafka-consumer-api

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

Dec 19, 2021

jms apache-kafka kafka-consumer-api jms-topic kafka-producer-api

Kafka topic partition and Spark executor mapping

Nov 13, 2022

java apache-spark apache-kafka spark-streaming kafka-consumer-api

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

Oct 22, 2021

apache-kafka kafka-consumer-api

kafka-console-consumer custom deserializer

Aug 23, 2022

apache-kafka kafka-consumer-api

How does Zookeeper/Kafka retain offset for a consumer?

Jul 06, 2022

apache-kafka kafka-consumer-api

Kafka Consumer Assignment returns Empty Set

Oct 24, 2022

java apache-kafka kafka-consumer-api

How to create a new consumer group in kafka

Sep 19, 2022

apache-kafka kafka-consumer-api

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

Oct 17, 2022

java apache-kafka kafka-consumer-api

How customer offsets are maintained in mirrored cluster in Kafka?

Nov 18, 2022

apache-kafka kafka-consumer-api apache-kafka-mirrormaker

How to set group name when consuming messages in kafka using command line?

Sep 07, 2022

apache-kafka kafka-consumer-api

New posts in kafka-consumer-api