kafka-consumer-api tutorials

Can I retrieve the latest available offset for a Kafka partition without retrieving all the messages?

May 31, 2022

apache-kafka kafka-consumer-api

Multithreaded Kafka Consumer or PerPartition-PerConsumer

Jul 29, 2018

apache-kafka kafka-consumer-api

multiprocessing in kafka-python

Nov 21, 2020

apache-kafka kafka-consumer-api kafka-python

Spring kafka consumer, seek offset at runtime?

Oct 31, 2022

apache-kafka kafka-consumer-api spring-kafka

how many consumer groups can a kafka topic handle?

Aug 26, 2022

apache-kafka kafka-consumer-api kafka-topic

How can I initialize kafka ConsumerRecords<String,String> in kafka for testing

Sep 14, 2022

java mocking apache-kafka powermock kafka-consumer-api

What's the best way to design message key in Kafka?

Sep 16, 2022

multithreading multiprocessing apache-kafka kafka-consumer-api kafka-producer-api

What is a listener container in Spring for Apache Kafka?

Sep 13, 2022

apache-kafka kafka-consumer-api spring-kafka

how to specify consumer group in Kafka Spark Streaming using direct stream

Nov 17, 2022

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

Kafka consumer.poll returns no records

Feb 25, 2022

java apache-kafka kafka-consumer-api

Kafka Acknowledgment vs Kafka commit

Oct 18, 2022

apache-kafka kafka-consumer-api spring-kafka

Kafka consumer does not start from latest message

Nov 11, 2022

apache-kafka kafka-consumer-api

Simple Kafka Consumer not receiving messages

Aug 26, 2022

java maven apache-kafka kafka-consumer-api

Why is Kafka consumer ignoring my "earliest" directive in the auto.offset.reset parameter and thus not reading my topic from the absolute first event?

May 26, 2022

java scala apache-spark apache-kafka kafka-consumer-api

Kafka consumer group offset retention

Aug 29, 2022

apache-kafka kafka-consumer-api

module 'snappy' has no attribute 'decompress'

Jun 03, 2020

python python-3.x kafka-consumer-api snappy

SBT cannot import Kafka encoder/decoder classes

Jul 15, 2019

apache-spark sbt apache-kafka spark-streaming kafka-consumer-api

kafka consumer to dynamically detect topics added

Oct 27, 2022

java apache-kafka kafka-consumer-api

New posts in kafka-consumer-api