radai rosenblatt created KAFKA-4839:
---------------------------------------
Summary: throw NoOffsetForPartitionException once for all assigned
partitions from poll
Key: KAFKA-4839
URL: https://issues.apache.org/jira/browse/KAFKA-4839
Project: Kafka
Issue Type: Improvement
Components: clients
Affects Versions: 0.10.2.0
Reporter: radai rosenblatt
Assignee: radai rosenblatt
KafkaConsumer.poll() will currently throw NoOffsetForPartitionException if
reset strategy is "none" and there are no defined offsets.
problem is the exception will only be thrown for the 1st such partition
encountered.
since a single consumer can be the owner of thousands of partitions this
results in a lot of exception that need to be caught and handled.
its possible to throw the exception once for all such TopicPartitions without
any user-visible API changes.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
