Advanced Kafka Consumer Tutorials with Java

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.