[
https://issues.apache.org/jira/browse/CAMEL-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen updated CAMEL-14968:
--------------------------------
Affects Version/s: (was: 3.x)
3.2.0
> 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.2.0
> Reporter: Leonardo Vasconcellos
> Priority: Minor
> Fix For: 3.3.0
>
>
> 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)
