[
https://issues.apache.org/jira/browse/CAMEL-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094486#comment-17094486
]
Claus Ibsen commented on CAMEL-14968:
-------------------------------------
Yeah sure, if you have some time and want, then you are welcome to try to
implement this and provide a PR
> Configurable shutdownAwaitTermination on Kafka Consumer Graceful Shutdown
> -------------------------------------------------------------------------
>
> Key: CAMEL-14968
> URL: https://issues.apache.org/jira/browse/CAMEL-14968
> Project: Camel
> Issue Type: Improvement
> Components: camel-kafka
> Affects Versions: 3.x
> Reporter: Leonardo Vasconcellos
> Priority: Minor
>
> Shutdown is forced when RouteController.stopRoute is called and the current
> batch of pulled messages from KafkaConsumer takes longer than 10 seconds to
> finish processing, logging lots of InterruptedExceptions from different
> points inside KafkaConsumer.
> KafkaConsumer.doStop method does not provide the shutdownAwaitTermination
> parameter to BaseExecutorServiceManager.shutdownGraceful. The default value
> is then set to 10 seconds.
> It would be nice to set in KafkaConsumer the shutdownAwaitTermination value
> so we dont have those exceptions in a controlled shutdown.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
