kafka-consumer-api tutorials

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

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

New posts in kafka-consumer-api