qafro1 commented on issue #1171: URL: https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844964385
After installing : Install camel-k on the kafka namespace kamel install -n kafka Run the following commands kubectl apply -f kafka-not-secured-sink.yaml -n kafka kubectl apply -f http-sink.kamelet.yaml -n kafka kubectl apply -f flow-binding.yaml -n kafka Check logs kamel logs timer-http-kafka -n kafka ``` camel-support-commons-logging, camel-support-httpclient, camel-timer, camel-yaml-dsl, cdi] [1] 2021-05-20 10:29:02,154 INFO [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Cluster ID: KhYIVrx9S3CaKCOtONrWdg [1] 2021-05-20 10:29:03,980 ERROR [org.apa.cam.pro.err.DefaultErrorHandler] (Camel (camel-1) thread #0 - timer://tick) Failed delivery for (MessageId: AAB47C0F94531D6-0000000000000000 on ExchangeId: AAB47C0F94531D6-0000000000000000). Exhausted after delivery attempt: 1 caught: org.apache.camel.http.common.HttpOperationFailedException: HTTP operation failed invoking http://httpbin.org/basic-auth/pippo/pippo with statusCode: 401 [1] [1] Message History (complete message history is disabled) [1] --------------------------------------------------------------------------------------------------------------------------------------- [1] RouteId ProcessorId Processor Elapsed (ms) [1] [source ] [source ] [from[timer://tick?period=5000] ] [ 1314] [1] ... [1] [action-0 ] [to4 ] [{{url}} ] [ 0] [1] [1] Stacktrace [1] --------------------------------------------------------------------------------------------------------------------------------------- [1] : org.apache.camel.http.common.HttpOperationFailedException: HTTP operation failed invoking http://httpbin.org/basic-auth/pippo/pippo with statusCode: 401 [1] at org.apache.camel.component.http.HttpProducer.populateHttpOperationFailedException(HttpProducer.java:419) [1] at org.apache.camel.component.http.HttpProducer.process(HttpProducer.java:291) [1] at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66) [1] at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172) [1] at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:439) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:62) [1] at org.apache.camel.processor.Pipeline.process(Pipeline.java:167) [1] at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:388) [1] at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:209) [1] at org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:76) [1] at java.base/java.util.TimerThread.mainLoop(Timer.java:556) [1] at java.base/java.util.TimerThread.run(Timer.java:506) [1] ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
