You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Leonardo Vasconcellos (Jira)" <ji...@apache.org> on 2020/04/26 02:42:00 UTC
[jira] [Created] (CAMEL-14968) Configurable
shutdownAwaitTermination on Kafka Consumer Graceful Shutdown
Leonardo Vasconcellos created CAMEL-14968:
---------------------------------------------
Summary: 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
Shutdown is forced when RouteController.stopRoute is called and the current batch of pulled messages 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)