You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "dvine (Jira)" <ji...@apache.org> on 2025/10/29 15:52:00 UTC
[jira] [Updated] (CAMEL-22627) Camel fails graceful shutdown with wiretap/kamelet
[ https://issues.apache.org/jira/browse/CAMEL-22627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
dvine updated CAMEL-22627:
--------------------------
Summary: Camel fails graceful shutdown with wiretap/kamelet (was: Camel fails gracefully shutdown with wiretap/kamelet)
> Camel fails graceful shutdown with wiretap/kamelet
> --------------------------------------------------
>
> Key: CAMEL-22627
> URL: https://issues.apache.org/jira/browse/CAMEL-22627
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 4.15.0
> Reporter: dvine
> Priority: Major
>
> We have long running tasks and set a large grace period during termination to clear these. What we see is errors like:
> org.apache.camel.component.kamelet.KameletConsumerNotAvailableException: No consumers available on endpoint: kamelet://<removed>?<removed>
> The code around this is called from a wiretap:
> .wireTap( kamelet://<removed>?<removed>") like so. If I replace it with .toD then we do not see the issue.
> During normal operation the logs show:
> [d #45 - WireTap] o.a.c.i.e.AbstractCamelContext : kamelet://<redacted> converted to endpoint: kamelet://<redacted> by component: org.apache.camel.component.kamelet.KameletComponent@320aecd3
> [d #45 - WireTap] o.a.c.s.s.BaseService$Holder : Starting service: kamelet://<redacted>
> [d #45 - WireTap] o.a.c.s.s.BaseService$Holder : Started service: kamelet://<redacted>
> [d #45 - WireTap] o.a.c.s.c.ServicePool : Creating service from endpoint: kamelet://<redacted>
> If camel is shutting down then it forgoese any starting service calls:
> [d #46 - WireTap] o.a.c.i.e.AbstractCamelContext : kamelet://<redacted> converted to endpoint: kamelet://<redacted> by component: org.apache.camel.component.kamelet.KameletComponent@3d1cb317
> [d #46 - WireTap] o.a.c.s.c.ServicePool : Creating service from endpoint: kamelet://<redacted>
> And then leads later to the KameletConsumerNotAvailableException.
> Which makes sense because the code around the starting only starts if camel is started and running from what I can see. However this means we cannot gracefully complete shutdown.
> I entered this as a bug because it seems to be a problem with wiretap/kamelets more specifically but advice regarding a work around for this would be appreciated. I havent managed to repeat this with non kamelets.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)