[jira] [Commented] (CAMEL-14968) Configurable shutdownAwaitTermination on Kafka Consumer Graceful Shutdown

["Claus Ibsen (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100734#comment-17100734 ] 

Claus Ibsen commented on CAMEL-14968:
-------------------------------------

Adding an option and using 30 sec as default timeout

> 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
>            Assignee: Claus Ibsen
>            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)