Looking at the following trace:
{"timestamp":"2024-07-29
16:33:24.735","level":"DEBUG","thread":"main","logger":"org.apache.camel.component.kubernetes.KubernetesHelper","message":"Create
Kubernetes client with the following Configuration: KubernetesConfiguration
[masterUrl=client&namespace=my-namespace, category=null,
kubernetesClient=null, username=null, password=null, operation=null,
apiVersion=null, caCertData=null, caCertFile=null, clientCertData=null,
clientCertFile=null, clientKeyAlgo=null, clientKeyData=null,
clientKeyFile=null, clientKeyPassphrase=null, oauthToken=null,
trustCerts=null, namespace=null, labelKey=null, labelValue=null,
resourceName=null, portName=null, dnsDomain=null, poolSize=1,
connectionTimeout=null]","context":"default"}
It seems you're missing to configure the credentials to let your
application authenticate against the cluster. Check the examples on the
component page [1] in order to get more reference about how to properly
configure it.
Cheers,
Pasquale.
[1]
https://camel.apache.org/components/4.4.x/kubernetes-events-component.html#_kubernetes_events_consumer_example
On Mon, Jul 29, 2024 at 7:59 PM Neuman, Benjamin J
<benjamin.neu...@optum.com.invalid> wrote:
> Hi all. I am attempting to implement a route which will receive k8 events
> and simply write them to system:out.
> The application is running in our cluster, however, it is not receiving
> any events. I'm hoping to get some info on how I might debug this issue.
> For reference, here is the route:
> from("kubernetes-events:client&namespace=my-namespace")
> .setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
> constant("my-namespace"))
> .process(new KubernertesProcessor())
> .to("stream:out");
> }
>
> public static class KubernertesProcessor implements Processor {
> @Override
> public void process(Exchange exchange) throws Exception {
> Message in = exchange.getIn();
> Event event = exchange.getIn().getBody(Event.class);
> log.info("Got event with event name: {} and action {}",
> event.getMetadata().getName(),
>
> in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
> }
> }
> and some logs that may be of use:
> {"timestamp":"2024-07-29
> 16:33:24.734","level":"DEBUG","thread":"main","logger":"org.apache.camel.impl.engine.InternalRouteStartupManager","message":"Warming
> up route id: route1 having autoStartup=true","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:24.735","level":"DEBUG","thread":"main","logger":"org.apache.camel.component.kubernetes.KubernetesHelper","message":"Create
> Kubernetes client with the following Configuration: KubernetesConfiguration
> [masterUrl=client&namespace=my-namespace, category=null,
> kubernetesClient=null, username=null, password=null, operation=null,
> apiVersion=null, caCertData=null, caCertFile=null, clientCertData=null,
> clientCertFile=null, clientKeyAlgo=null, clientKeyData=null,
> clientKeyFile=null, clientKeyPassphrase=null, oauthToken=null,
> trustCerts=null, namespace=null, labelKey=null, labelValue=null,
> resourceName=null, portName=null, dnsDomain=null, poolSize=1,
> connectionTimeout=null]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.337","level":"DEBUG","thread":"main","logger":"org.apache.camel.impl.engine.InternalRouteStartupManager","message":"Route:
> route1 >>> Route[kubernetes-events://client&namespace=my-namespace ->
> null]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.337","level":"DEBUG","thread":"main","logger":"org.apache.camel.impl.engine.InternalRouteStartupManager","message":"Starting
> consumer (order: 1000) on route: route1","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.338","level":"DEBUG","thread":"main","logger":"org.apache.camel.support.DefaultConsumer","message":"Build
> consumer:
> Consumer[kubernetes-events://client&namespace=my-namespace]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.338","level":"DEBUG","thread":"main","logger":"org.apache.camel.support.DefaultConsumer","message":"Init
> consumer:
> Consumer[kubernetes-events://client&namespace=my-namespace]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.339","level":"DEBUG","thread":"main","logger":"org.apache.camel.support.DefaultConsumer","message":"Starting
> consumer:
> Consumer[kubernetes-events://client&namespace=my-namespace]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.339","level":"DEBUG","thread":"main","logger":"org.apache.camel.impl.engine.BaseExecutorServiceManager","message":"Created
> new ThreadPool for source:
> kubernetes-events://client&namespace=my-namespace with name:
> KubernetesConsumer. ->
> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@46b7c89b
> [Running<mailto:
> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@46b7c89b[Running>,
> pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
> 0][KubernetesConsumer]","context":"default"}
> {"timestamp":"2024-07-29
> 16:33:25.343","level":"DEBUG","thread":"main","logger":"org.apache.camel.impl.engine.InternalRouteStartupManager","message":"Route:
> route1 started and consuming from:
> kubernetes-events://client&namespace=my-namespace","context":"default"}
> Any help/guidance is greatly appreciated.
>
> This e-mail, including attachments, may include confidential and/or
> proprietary information, and may be used only by the person or entity
> to which it is addressed. If the reader of this e-mail is not the intended
> recipient or intended recipient’s authorized agent, the reader is hereby
> notified that any dissemination, distribution or copying of this e-mail is
> prohibited. If you have received this e-mail in error, please notify the
> sender by replying to this message and delete this e-mail immediately.
>
