kafka-consumer-api tutorials

How to fix: java.lang.OutOfMemoryError: Direct buffer memory in flink kafka consumer

Aug 21, 2021

Why don't Kafka's seekToBeginning and seekToEnd work with assign?

Nov 17, 2022

java apache-kafka kafka-consumer-api

Zookeeper sessions keep expiring...no heartbeats?

Jun 03, 2022

apache-kafka apache-zookeeper session-timeout kafka-consumer-api

Kafka Stream API vs Consumer API

Sep 26, 2022

apache-kafka kafka-consumer-api apache-kafka-streams

Is there any way to maintain message ordering between partitions of a kafka topic with a single consumer?

Nov 16, 2022

streaming apache-kafka kafka-consumer-api

Read Kafka topic in a Spark batch job

Nov 04, 2022

scala apache-spark apache-kafka spark-streaming kafka-consumer-api

How to delete kafka consumer group (created via new consumer api)?

Jan 30, 2018

java apache-kafka kafka-consumer-api

Delete unused kafka consumer group

May 08, 2022

apache-kafka kafka-consumer-api apache-kafka-streams

How to get last consumed offset for a consumer group?

Jun 09, 2022

java apache-kafka kafka-consumer-api

Kafka High-level Consumer error_code=15

Jun 17, 2022

apache-kafka kafka-consumer-api

Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1001: org.apache.kafka.common.errors.DisconnectException

Apr 17, 2022

apache-kafka kafka-consumer-api spring-kafka

How to make Spark Streaming (Spark 1.0.0) read the latest data from Kafka (Kafka Broker 0.8.1)

Apr 04, 2022

apache-spark apache-kafka spark-streaming offset kafka-consumer-api

Why do we need to mention Zookeeper details even though Apache Kafka configuration file already has it?

Aug 22, 2020

apache-kafka apache-zookeeper kafka-consumer-api

How does Kinesis achieve Kafka style Consumer Groups?

Oct 30, 2022

apache-kafka kafka-consumer-api amazon-kinesis

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

New posts in kafka-consumer-api