[ https://issues.apache.org/jira/browse/KAFKA-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-2662. -------------------------------- Resolution: Auto Closed The Scala consumers are no longer supported. Please upgrade to the Java consumer whenever possible. > Make ConsumerIterator thread-safe for multiple threads in different Kafka > groups > -------------------------------------------------------------------------------- > > Key: KAFKA-2662 > URL: https://issues.apache.org/jira/browse/KAFKA-2662 > Project: Kafka > Issue Type: Improvement > Components: consumer > Affects Versions: 0.8.2.1 > Reporter: Andrew Pennebaker > Assignee: Neha Narkhede > > The API for obtaining a ConsumerIterator requires a group parameter, implying > that ConsumerIterators are thread-safe, as long as each thread is in a > different Kafka group. However, in practice, attempting to call hasNext() on > ConsumerIterators for a thread in one group, and for a thread in another > group, results in an InvalidStateException. > In the future, can we please make ConsumerIterator thread-safe, for a common > use case of one consumer thread per group? -- This message was sent by Atlassian JIRA (v6.4.14#64029)