kafka-consumer-api tutorials

Kafka Partitions Reassignment Performance Impact

Jun 24, 2022

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

kafka-node start consume from last offset

Mar 23, 2022

node.js apache-kafka kafka-consumer-api

Zookeeper communication protocol

Nov 05, 2022

apache-zookeeper kafka-consumer-api

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

Sep 22, 2022

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

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

New posts in kafka-consumer-api