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.

Was this content helpful?
PreviousComplete Kafka Consumer with Java
NextJava Consumer Rebalance Listener