I have been experimenting with the KafkaConsumer currently in development [1]. Sorry if this should be a question for the user list, but I am not sure if what I am seeing is something not working yet or if I am misunderstanding the API. If I use KafkaConsumer#subscribe to subscribe to a topic and then try to use seek(TopicPartion, offset) to position the consumer, I get an IllegalStateException with message "No current assignment for partition ...." If I use assign instead to connect to the topic, things work fine. I can see why this is by looking at the SubscriptionState code which is throwing the ISE because SubscriptionState#seek expects to find an assignment, but KafkaConsumer#subscribe does not make any.
I know this is unreleased code and I am not looking for help here - actually more like looking *to* help but just learning the code. Happy to open a ticket with a test case if that will help or a patch to the javadoc if I am misunderstanding the API and it can be made clearer. Thanks! Phil [1] ff189fa05ccdacac100f3d15d167dcbe561f57a6
