Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-14968

Configurable shutdownAwaitTermination on Kafka Consumer Graceful Shutdown

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 3.2.0
    • 3.3.0
    • camel-kafka
    • None
    • Unknown

    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 in a controlled shutdown.

      Attachments

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            davsclaus Claus Ibsen
            LeonardoZV Leonardo Vasconcellos
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment