iamrsaravana commented on issue #817:
URL:
https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751322445
Strimzi operator logs say below error message:
2020-12-26 05:54:31 INFO AbstractConnectOperator:436 - Reconciliation
#37(timer) KafkaConnect(kafka/my-connect-cluster): creating/updating connector:
camelamqpsourceconnector
2020-12-26 05:54:31 WARN AbstractConnectOperator:573 - Reconciliation
#37(timer) KafkaConnect(kafka/my-connect-cluster): **Error reconciling
connector camelamqpsourceconnect**or
io.strimzi.operator.cluster.operator.assembly.ConnectRestException: PUT
/connectors/camelamqpsourceconnector/config returned 500 (Internal Server
Error): Failed to find any class that implements Connector and which name
matches org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector,
available connectors are: PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSinkConnector,
name='org.apache.camel.kafkaconnector.CamelSinkConnector', version='0.6.1',
encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSourceConnector,
name='org.apache.camel.kafkaconnector.CamelSourceConnector', version='0.6.1',
encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector',
version='0.6
.1', encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector',
version='0.6.1', encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.kafka.connect.file.FileStreamSinkConnector,
name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector,
name='org.apache.kafka.connect.file.FileStreamSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorCheckpointConnector,
name='org.apache.kafka.connect.mirror.MirrorCheckpointConnect
or', version='1', encodedVersion=1, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorHeartbeatConnector,
name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector,
name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector,
name='org.apache.kafka.connect.tools.MockConnector', version='2.6.0',
encodedVersion=2.6.0, type=connector, typeName='connector',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.MockSinkConnector,
name='org.apache.kafka.connect.tools.MockSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'}, Plugin
Desc{klass=class org.apache.kafka.connect.tools.MockSourceConnector,
name='org.apache.kafka.connect.tools.MockSourceConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector,
name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector,
name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class
org.apache.kafka.connect.tools.VerifiableSourceConnector,
name='org.apache.kafka.connect.tools.VerifiableSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}
at
io.strimzi.operator.cluster.operator.assembly.KafkaConnectApiImpl.lambda$createOrUpdatePutRequest$1(KafkaConnectApiImpl.java:84)
~[io.strimzi.cluster-operator-0.20.1.jar:0.20.1]
at
io.vertx.core.http.impl.HttpClientResponseImpl$BodyHandler.notifyHandler(HttpClientResponseImpl.java:292)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.HttpClientResponseImpl.lambda$bodyHandler$0(HttpClientResponseImpl.java:193)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.HttpClientResponseImpl.handleEnd(HttpClientResponseImpl.java:248)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.lambda$beginResponse$0(Http1xClientConnection.java:483)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.streams.impl.InboundBuffer.handleEvent(InboundBuffer.java:237)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.streams.impl.InboundBuffer.write(InboundBuffer.java:127)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.endResponse(Http1xClientConnection.java:502)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.access$000(Http1xClientConnection.java:241)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection.handleResponseEnd(Http1xClientConnection.java:641)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection.handleHttpMessage(Http1xClientConnection.java:601)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.http.impl.Http1xClientConnection.handleMessage(Http1xClientConnection.java:575)
~[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at io.vertx.core.impl.ContextImpl.executeTask(ContextImpl.java:366)
[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.impl.EventLoopContext.execute(EventLoopContext.java:43)
[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.impl.ContextImpl.executeFromIO(ContextImpl.java:229)
[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.vertx.core.net.impl.VertxHandler.channelRead(VertxHandler.java:173)
[io.vertx.vertx-core-3.9.1.jar:3.9.1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
[io.netty.netty-codec-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
[io.netty.netty-codec-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.handler.logging.LoggingHandler.channelRead(LoggingHandler.java:271)
[io.netty.netty-handler-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
[io.netty.netty-transport-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
[io.netty.netty-common-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[io.netty.netty-common-4.1.50.Final.jar:4.1.50.Final]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty.netty-common-4.1.50.Final.jar:4.1.50.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
2020-12-26 05:54:31 INFO AbstractOperator:457 - Reconciliation #37(timer)
KafkaConnect(kafka/my-connect-cluster): reconciled
2020-12-26 05:54:34 INFO AbstractOperator:457 - Reconciliation #35(timer)
Kafka(kafka/my-cluster): reconciled
**but my connector cluster is running without any error message**. i have
attached (pod/my-connect-cluster-connect-5c84678dd9-dhjj7 ) logs
[my-connect-cluster-connect-5c84678dd9-dhjj7
.txt](https://github.com/apache/camel-kafka-connector/files/5742738/my-connect-cluster-connect-5c84678dd9-dhjj7.txt)
----------------------------------------------------------------
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]
