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.