New posts in kafka-consumer-api

Topics, partitions and keys

difference between groupid and consumerid in Kafka consumer

How to stop Spring Kafka Listner and invoke some function to execute after the Consumer is stopped?

Kafka Msg VS REST Calls

How to read data using Kafka Consumer API from beginning?

Docker Kafka w/ Python consumer

Run a method once after spring kafka consumer starts

What does "Rebalancing" mean in Apache Kafka context?

Can multiple Kafka consumers read same message from the partition

Delete message after consuming it in KAFKA

Kafka consumer list

kafka + describe views for ConsumerGroupCommand

Difference between and for Kafka >= 0.10.1

Kafka Consumer Vs Apache Flink

Kafka: Consumer API vs Streams API

Is key required as part of sending messages to Kafka?

What determines Kafka consumer offset?

Understanding Kafka Topics and Partitions