kafka-consumer-api tutorials

How does (should) Kafka Consumer cope with Poison Messages

Oct 29, 2022

apache-kafka kafka-consumer-api

apache- kafka with 100 millions of topics

Nov 08, 2022

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

How to find which consumer is assigned to which partition of a topic in kafka?

May 19, 2019

java apache-kafka kafka-consumer-api apache-zookeeper

Conditions in which Kafka Consumer (Group) triggers a rebalance

Oct 29, 2022

apache-kafka kafka-consumer-api

Kafka Consumer seektoBeginning

Apr 10, 2021

apache-kafka kafka-consumer-api

How to stop Python Kafka Consumer in program?

Apr 25, 2022

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

how to get acknowledgement from Kafka broker if message is produced by producer?

Feb 19, 2019

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

Kafka CommitFailedException consumer exception

Sep 25, 2022

java apache-kafka kafka-consumer-api

Kafka streams.allMetadata() method returns empty list

Oct 14, 2021

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

Kafka Consumer: How to start consuming from the last message in Python

Feb 25, 2021

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

INFO Closed socket connection for client /127.0.0.1:48452 which had sessionid 0x15698f5ac360001 (org.apache.zookeeper.server.NIOServerCnxn)

Jul 07, 2017

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

Pausing a kafka topic with multiple consumers

Nov 11, 2021

java apache-kafka kafka-consumer-api

Is kafka consumer 0.9 backward compatible?

Mar 22, 2022

apache-kafka kafka-consumer-api

Kafka multiple partition ordering

Nov 05, 2022

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

Kafka console consumer get partition

Mar 26, 2022

java apache-kafka kafka-consumer-api

How to choose the no of partitions for a kafka topic?

Aug 22, 2022

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

kafka-python consumer start reading from offset (automatically)

Nov 07, 2022

python-3.x apache-kafka offset kafka-consumer-api kafka-python

kafka consumer sessions timing out

Sep 22, 2022

apache-kafka kafka-consumer-api

How to pass dynamic topic name to @KafkaListener(topics) from environment variable

Nov 07, 2022

java spring-boot kafka-consumer-api spring-kafka spring-el

New posts in kafka-consumer-api