Advanced Kafka Consumer Tutorials with Java
A series of tutorials covering more advanced Java programming tasks for Kafka Consumers
The previous code examples should be enough for 90% of your use cases.
Here, we have included advanced examples for the following use cases:
Consumer Rebalance Listener: in case you're doing a manual commit of your offsets to Kafka or externally, this allows you to commit offsets when partitions are revoked from your consumer.
Consumer Seek and Assign: if instead of using consumer groups, you want to start at specific offsets and consume only specific partitions, you will learn about the
.seek()
and.assign()
APIs.Consumer in Threads: very advanced code samples, this is for those who want to run their consumer
.poll()
loop in a separate thread.
PreviousComplete Kafka Consumer with Java
NextJava Consumer Rebalance Listener