You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Abhinav Dixit (Jira)" <ji...@apache.org> on 2025/06/30 13:05:00 UTC

[jira] [Created] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer

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)