Abhinav Dixit created KAFKA-19450:
-------------------------------------
Summary: ShareConsumerPerformance does not handle exceptions from
consumeMessagesForSingleShareConsumer
Key: KAFKA-19450
URL: https://issues.apache.org/jira/browse/KAFKA-19450
Project: Kafka
Issue Type: Sub-task
Reporter: Abhinav Dixit
Within {{{}ShareConsumerPerformance.java,a{}}}ll the share consumers run with
within an {{executorService}} object and when we perform
{{executorService.submit()}} in {{{}ShareConsumerPerformance{}}}, we do not
store this future and exception would be recovered only when we do a
{{future.get()}} in this case. I believe this is a shortcoming in
{{ShareConsumerPerformance.java}} which needs to be improved.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
