- How to use rebalance listeners for manual offset commits
- How to use seek() and assign() for specific partition/offset access
- How to run consumers in separate threads
Advanced tutorials
| Tutorial | Use case |
|---|---|
| Rebalance Listener | Manual offset commits, external offset storage |
| Seek and Assign | Replay from specific offset, read specific partitions |
| Consumer in Threads | Background polling, concurrent processing |
See it in practice with ConduktorConduktor Console helps you debug advanced consumer scenarios by showing partition assignments, committed offsets, and consumer lag in real-time.
Next steps
- Implement rebalance listeners for manual offset management
- Use seek and assign for replay scenarios
- Run consumers in threads for concurrent processing
- Understand delivery semantics for reliable processing