Loading...

Type: Bug
Resolution: Done
Priority: Critical
Fix Version/s: camel-k-1.6.6
Affects Version/s: None
Component/s: Camel-3, Camel-K
Labels:
None

Blocked:
False
Ready:
False
Fuse Progress Bar:

% %
QE Test Coverage:
+
Regression Test:
Automated
Release Note Text:
Undefined
Target Release:

2021-M2
Market:

SFDC Cases Counter:
SFDC Cases Links:

When using camel-slack-kafka-connector sink, it always works for 1st message (that is successfully posted to the slack channel), but all subsequent messages fail with:

2021-03-09 15:21:18,859 [SinkConnector-0] DEBUG org.apache.camel.kafkaconnector.CamelSinkTask - Sending exchange B44717002406616-0000000000000001 to direct:start
2021-03-09 15:21:18,917 [SinkConnector-0] ERROR org.apache.camel.processor.errorhandler.DefaultErrorHandler - Failed delivery for (MessageId: B44717002406616-0000000000000001 on ExchangeId: B44717002406616-0000000000000001). Exhausted after delivery attempt: 1 caught: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated

Message History (complete message history is disabled)
---------------------------------------------------------------------------------------------------------------------------------------
RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
[route1            ] [route1            ] [                                                                              ] [        58]
	...
[route1            ] [toD1              ] [slack:#tests?webhookUrl=https://hooks.slack.com/services/T01QM4LAPJN/B01QZPHSE] [         0]

Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------

javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated
	at sun.security.ssl.SSLSessionImpl.getPeerCertificates(SSLSessionImpl.java:526) ~[?:?]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.verifyHostname(SSLConnectionSocketFactory.java:504) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.createLayeredSocket(SSLConnectionSocketFactory.java:437) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.connectSocket(SSLConnectionSocketFactory.java:384) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.camel.component.slack.SlackProducer.process(SlackProducer.java:76) ~[camel-slack-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66) ~[camel-support-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:195) ~[camel-core-processor-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:317) ~[camel-support-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:180) ~[camel-core-processor-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395) [camel-core-processor-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:147) [camel-core-processor-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:84) [camel-direct-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:218) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:112) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:109) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:189) [camel-support-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148) [camel-base-engine-3.7.0.fuse-800004-redhat-00001.jar:3.7.0.fuse-800004-redhat-00001]
	at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:181) [camel-kafka-connector-0.7.1.fuse-800003-redhat-00001.jar:0.7.1.fuse-800003-redhat-00001]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:560) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:323) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:226) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:198) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235) [connect-runtime-2.6.0.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
	at java.lang.Thread.run(Thread.java:834) [?:?]
2021-03-09 15:21:18,920 [SinkConnector-0] WARN org.apache.camel.kafkaconnector.CamelSinkTask - A delivery has failed and the error reporting is NOT enabled. Records may be lost or ignored
2021-03-09 15:21:18,921 [SinkConnector-0] ERROR org.apache.kafka.connect.runtime.WorkerSinkTask - WorkerSinkTask{id=CamelSlackSinkConnector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Exchange delivery has failed!
org.apache.kafka.connect.errors.ConnectException: Exchange delivery has failed!
	at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:186) ~[camel-kafka-connector-0.7.1.fuse-800001-redhat-00001.jar:0.7.1.fuse-800001-redhat-00001]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:560) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:323) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:226) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:198) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235) [connect-runtime-2.6.0.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
	at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated
	at sun.security.ssl.SSLSessionImpl.getPeerCertificates(SSLSessionImpl.java:526) ~[?:?]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.verifyHostname(SSLConnectionSocketFactory.java:504) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.createLayeredSocket(SSLConnectionSocketFactory.java:437) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.connectSocket(SSLConnectionSocketFactory.java:384) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.camel.component.slack.SlackProducer.process(SlackProducer.java:76) ~[camel-slack-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:195) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:317) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:180) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:147) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:84) ~[camel-direct-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:218) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:112) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:109) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:189) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:181) ~[camel-kafka-connector-0.7.1.fuse-800001-redhat-00001.jar:0.7.1.fuse-800001-redhat-00001]
	... 11 more
2021-03-09 15:21:18,928 [SinkConnector-0] ERROR org.apache.kafka.connect.runtime.WorkerTask - WorkerSinkTask{id=CamelSlackSinkConnector-0} Task threw an uncaught and unrecoverable exception
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:588) ~[connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:323) ~[connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:226) ~[connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:198) ~[connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) [connect-runtime-2.6.0.jar:?]
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235) [connect-runtime-2.6.0.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
	at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: org.apache.kafka.connect.errors.ConnectException: Exchange delivery has failed!
	at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:186) ~[camel-kafka-connector-0.7.1.fuse-800001-redhat-00001.jar:0.7.1.fuse-800001-redhat-00001]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:560) ~[connect-runtime-2.6.0.jar:?]
	... 10 more
Caused by: javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated
	at sun.security.ssl.SSLSessionImpl.getPeerCertificates(SSLSessionImpl.java:526) ~[?:?]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.verifyHostname(SSLConnectionSocketFactory.java:504) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.createLayeredSocket(SSLConnectionSocketFactory.java:437) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.conn.ssl.SSLConnectionSocketFactory.connectSocket(SSLConnectionSocketFactory.java:384) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56) ~[httpclient-4.5.13.redhat-00002.jar:4.5.13.redhat-00002]
	at org.apache.camel.component.slack.SlackProducer.process(SlackProducer.java:76) ~[camel-slack-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.lambda$process$0(SendDynamicProcessor.java:195) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:317) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:180) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:147) ~[camel-core-processor-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:84) ~[camel-direct-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:218) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:112) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:109) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:189) ~[camel-support-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148) ~[camel-base-engine-3.7.0.fuse-800002-redhat-00001.jar:3.7.0.fuse-800002-redhat-00001]
	at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:181) ~[camel-kafka-connector-0.7.1.fuse-800001-redhat-00001.jar:0.7.1.fuse-800001-redhat-00001]
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:560) ~[connect-runtime-2.6.0.jar:?]
	... 10 more
2021-03-09 15:21:18,929 [SinkConnector-0] ERROR org.apache.kafka.connect.runtime.WorkerTask - WorkerSinkTask{id=CamelSlackSinkConnector-0} Task is being killed and will not recover until manually restarted
2021-03-09 15:21:18,929 [SinkConnector-0] INFO org.apache.camel.kafkaconnector.CamelSinkTask - Stopping CamelSinkTask connector task
2021-03-09 15:21:18,929 [SinkConnector-0] INFO org.apache.camel.impl.engine.AbstractCamelContext - Apache Camel 3.7.0.fuse-800002-redhat-00001 (camel-1) is shutting down
2021-03-09 15:21:18,930 [SinkConnector-0] INFO org.apache.camel.impl.engine.DefaultShutdownStrategy - Starting to graceful shutdown 1 routes (timeout 45 seconds)
2021-03-09 15:21:18,931 [ - ShutdownTask] INFO org.apache.camel.impl.engine.DefaultShutdownStrategy - Route: route1 shutdown complete, was consuming from: direct://start
2021-03-09 15:21:18,931 [SinkConnector-0] INFO org.apache.camel.impl.engine.DefaultShutdownStrategy - Graceful shutdown of 1 routes completed in 2ms
2021-03-09 15:21:18,933 [SinkConnector-0] INFO org.apache.camel.impl.engine.AbstractCamelContext - Apache Camel 3.7.0.fuse-800002-redhat-00001 (camel-1) uptime 1s280ms
2021-03-09 15:21:18,933 [SinkConnector-0] INFO org.apache.camel.impl.engine.AbstractCamelContext - Apache Camel 3.7.0.fuse-800002-redhat-00001 (camel-1) is shutdown in 4ms
2021-03-09 15:21:18,933 [SinkConnector-0] INFO org.apache.camel.kafkaconnector.CamelSinkTask - CamelSinkTask connector task stopped

Using following sink connector properties:

connector.class=org.apache.camel.kafkaconnector.slack.CamelSlackSinkConnector    
tasks.max=1    
topics=mytopic    
camel.sink.path.channel=#tests    
name=CamelSlackSinkConnector    
value.converter=org.apache.kafka.connect.storage.StringConverter    
key.converter=org.apache.kafka.connect.storage.StringConverter    
camel.sink.endpoint.webhookUrl=https://hooks.slack.com/<my webhook>

Also reproducible with standalone upstream 3.0.0 and 3.7.0 versions with following route:

from("timer://foo?fixedRate=true&period=30000").setBody(constant("standalone")).to("slack:#tests?webhookUrl=https://hooks.slack.com/<my webhook>");

Details

Description

Attachments

Activity

People

Dates