Andrew Pennebaker created KAFKA-2662:
----------------------------------------
Summary: 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.3.4#6332)
