kafka-consumer-api tutorials

What happens if offset specified by kafka consumer is not present in Broker?

Sep 22, 2022

Is it possible to read from multiple partitions using Kafka Simple Consumer?

Oct 03, 2022

apache-kafka kafka-consumer-api

How to programmatically check if Kafka Broker is up and running in Python

May 16, 2022

python apache-kafka kafka-consumer-api kafka-python

How to close kafka consumer once all messages are consumed?

Oct 15, 2022

python python-3.x kafka-consumer-api

Kafka: How to Display Offsets

Sep 14, 2022

apache-kafka kafka-consumer-api

Difference in kafka 0.8 with kafka 0.10

Aug 16, 2022

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

Don't print the kafka-console-consumer warnings

Dec 24, 2018

apache-kafka suppress-warnings kafka-consumer-api

Kafka: Single consumer group in multiple instances

Jun 11, 2022

java apache-kafka kafka-consumer-api

Kafka Connect JDBC sink connector not working

Sep 17, 2022

apache-kafka kafka-consumer-api apache-kafka-connect

How to pass topics dynamically to a kafka listener?

May 08, 2022

java apache-kafka kafka-consumer-api

ERROR org.apache.kafka.common.utils.KafkaThread - Uncaught exception in thread 'kafka-producer-network-thread

Jun 08, 2022

java multithreading apache-kafka kafka-consumer-api kafka-producer-api

java.lang.ClassCastException:xx cannot be cast to org.apache.avro.generic.IndexedRecord

Sep 04, 2017

java apache-kafka avro kafka-consumer-api

What should I use: Kafka Stream or Kafka consumer api or Kafka connect

Nov 08, 2022

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

Kafka: How to get last modified time for a topic i.e. last message added to any partition of the topic

Mar 24, 2022

apache-kafka kafka-consumer-api

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

Aug 21, 2021

apache-kafka apache-flink kafka-consumer-api flink-streaming

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

New posts in kafka-consumer-api