[
https://issues.apache.org/jira/browse/CAMEL-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonardo Vasconcellos updated CAMEL-14968:
------------------------------------------
Description:
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.
was:
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.
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
