kafka-seek

Kafka IllegalStateException: No Current Assignment for Partition

Getting java.lang.IllegalStateException: No current assignment for partition on seek()? Why Kafka's lazy assignment causes it — and the correct fix.