[2022-03-18 16:09:43,898] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:68)
[2022-03-18 16:09:43,906] INFO WorkerInfo values:
jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/root/kafka/bin/../logs, -Dlog4j.configuration=file:./bin/../config/connect-log4j.properties
jvm.spec = Azul Systems, Inc., OpenJDK 64-Bit Server VM, 1.8.0_282, 25.282-b08
jvm.classpath = /root/kafka/bin/../libs/activation-1.1.1.jar:/root/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/root/kafka/bin/../libs/argparse4j-0.7.0.jar:/root/kafka/bin/../libs/audience-annotations-0.5.0.jar:/root/kafka/bin/../libs/commons-cli-1.4.jar:/root/kafka/bin/../libs/commons-lang3-3.8.1.jar:/root/kafka/bin/../libs/connect-api-3.0.0.jar:/root/kafka/bin/../libs/connect-basic-auth-extension-3.0.0.jar:/root/kafka/bin/../libs/connect-file-3.0.0.jar:/root/kafka/bin/../libs/connect-json-3.0.0.jar:/root/kafka/bin/../libs/connect-mirror-3.0.0.jar:/root/kafka/bin/../libs/connect-mirror-client-3.0.0.jar:/root/kafka/bin/../libs/connect-runtime-3.0.0.jar:/root/kafka/bin/../libs/connect-transforms-3.0.0.jar:/root/kafka/bin/../libs/hk2-api-2.6.1.jar:/root/kafka/bin/../libs/hk2-locator-2.6.1.jar:/root/kafka/bin/../libs/hk2-utils-2.6.1.jar:/root/kafka/bin/../libs/jackson-annotations-2.12.3.jar:/root/kafka/bin/../libs/jackson-core-2.12.3.jar:/root/kafka/bin/../libs/jackson-databind-2.12.3.jar:/root/kafka/bin/../libs/jackson-dataformat-csv-2.12.3.jar:/root/kafka/bin/../libs/jackson-datatype-jdk8-2.12.3.jar:/root/kafka/bin/../libs/jackson-jaxrs-base-2.12.3.jar:/root/kafka/bin/../libs/jackson-jaxrs-json-provider-2.12.3.jar:/root/kafka/bin/../libs/jackson-module-jaxb-annotations-2.12.3.jar:/root/kafka/bin/../libs/jackson-module-scala_2.13-2.12.3.jar:/root/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/root/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/root/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/root/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/root/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/root/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/root/kafka/bin/../libs/javassist-3.27.0-GA.jar:/root/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/root/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/root/kafka/bin/../libs/jaxb-api-2.3.0.jar:/root/kafka/bin/../libs/jersey-client-2.34.jar:/root/kafka/bin/../libs/jersey-common-2.34.jar:/root/kafka/bin/../libs/jersey-container-servlet-2.34.jar:/root/kafka/bin/../libs/jersey-container-servlet-core-2.34.jar:/root/kafka/bin/../libs/jersey-hk2-2.34.jar:/root/kafka/bin/../libs/jersey-server-2.34.jar:/root/kafka/bin/../libs/jetty-client-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-continuation-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-http-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-io-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-security-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-server-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-servlet-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-servlets-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-util-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jetty-util-ajax-9.4.43.v20210629.jar:/root/kafka/bin/../libs/jline-3.12.1.jar:/root/kafka/bin/../libs/jopt-simple-5.0.4.jar:/root/kafka/bin/../libs/kafka-clients-3.0.0.jar:/root/kafka/bin/../libs/kafka-log4j-appender-3.0.0.jar:/root/kafka/bin/../libs/kafka-metadata-3.0.0.jar:/root/kafka/bin/../libs/kafka-raft-3.0.0.jar:/root/kafka/bin/../libs/kafka-server-common-3.0.0.jar:/root/kafka/bin/../libs/kafka-shell-3.0.0.jar:/root/kafka/bin/../libs/kafka-storage-3.0.0.jar:/root/kafka/bin/../libs/kafka-storage-api-3.0.0.jar:/root/kafka/bin/../libs/kafka-streams-3.0.0.jar:/root/kafka/bin/../libs/kafka-streams-examples-3.0.0.jar:/root/kafka/bin/../libs/kafka-streams-scala_2.13-3.0.0.jar:/root/kafka/bin/../libs/kafka-streams-test-utils-3.0.0.jar:/root/kafka/bin/../libs/kafka-tools-3.0.0.jar:/root/kafka/bin/../libs/kafka_2.13-3.0.0.jar:/root/kafka/bin/../libs/log4j-1.2.17.jar:/root/kafka/bin/../libs/lz4-java-1.7.1.jar:/root/kafka/bin/../libs/maven-artifact-3.8.1.jar:/root/kafka/bin/../libs/metrics-core-2.2.0.jar:/root/kafka/bin/../libs/metrics-core-4.1.12.1.jar:/root/kafka/bin/../libs/netty-buffer-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-codec-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-common-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-handler-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-resolver-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-transport-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/root/kafka/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/root/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/root/kafka/bin/../libs/paranamer-2.8.jar:/root/kafka/bin/../libs/plexus-utils-3.2.1.jar:/root/kafka/bin/../libs/reflections-0.9.12.jar:/root/kafka/bin/../libs/rocksdbjni-6.19.3.jar:/root/kafka/bin/../libs/scala-collection-compat_2.13-2.4.4.jar:/root/kafka/bin/../libs/scala-java8-compat_2.13-1.0.0.jar:/root/kafka/bin/../libs/scala-library-2.13.6.jar:/root/kafka/bin/../libs/scala-logging_2.13-3.9.3.jar:/root/kafka/bin/../libs/scala-reflect-2.13.6.jar:/root/kafka/bin/../libs/slf4j-api-1.7.30.jar:/root/kafka/bin/../libs/slf4j-log4j12-1.7.30.jar:/root/kafka/bin/../libs/snappy-java-1.1.8.1.jar:/root/kafka/bin/../libs/trogdor-3.0.0.jar:/root/kafka/bin/../libs/zookeeper-3.6.3.jar:/root/kafka/bin/../libs/zookeeper-jute-3.6.3.jar:/root/kafka/bin/../libs/zstd-jni-1.5.0-2.jar
os.spec = Linux, amd64, 3.0.101-0.235.TDC.1.R.0-default
os.vcpus = 72
(org.apache.kafka.connect.runtime.WorkerInfo:71)
[2022-03-18 16:09:43,906] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:77)
[2022-03-18 16:09:43,923] INFO Loading plugin from: /root/connectors/camel-cql-kafka-connector (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:265)
[2022-03-18 16:09:45,011] INFO Registered loader: PluginClassLoader{pluginLocation=file:/root/connectors/camel-cql-kafka-connector/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:288)
[2022-03-18 16:09:45,011] INFO Added plugin 'org.apache.camel.kafkaconnector.CamelSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,011] INFO Added plugin 'org.apache.camel.kafkaconnector.CamelSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,011] INFO Added plugin 'org.apache.camel.kafkaconnector.cql.CamelCqlSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,011] INFO Added plugin 'org.apache.camel.kafkaconnector.cql.CamelCqlSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'io.apicurio.registry.utils.converter.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'io.apicurio.registry.utils.converter.ExtJsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'io.apicurio.registry.utils.converter.SchemalessConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.FieldsToHeadersTransform$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.SinkPojoToSchemaAndStructTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,012] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.FieldsToHeadersTransform$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,013] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.SourcePojoToSchemaAndStructTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,013] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.CamelTypeConverterTransform$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,013] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,013] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.CamelTypeConverterTransform$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,013] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,014] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,014] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,014] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,014] INFO Loading plugin from: /root/connectors/docs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:265)
[2022-03-18 16:09:45,016] INFO Registered loader: PluginClassLoader{pluginLocation=file:/root/connectors/docs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:288)
[2022-03-18 16:09:45,016] INFO Loading plugin from: /root/connectors/camel-cassandra-sink-kafka-connector (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:265)
[2022-03-18 16:09:45,724] INFO Registered loader: PluginClassLoader{pluginLocation=file:/root/connectors/camel-cassandra-sink-kafka-connector/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:288)
[2022-03-18 16:09:45,724] INFO Added plugin 'org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:45,724] INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.ConnectRecordValueToMapTransforms' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:288)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,529] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,530] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,531] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,532] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,533] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2022-03-18 16:09:46,533] INFO Added aliases 'CamelCassandrasinkSinkConnector' and 'CamelCassandrasinkSink' to plugin 'org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,533] INFO Added aliases 'CamelCqlSinkConnector' and 'CamelCqlSink' to plugin 'org.apache.camel.kafkaconnector.cql.CamelCqlSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,533] INFO Added aliases 'CamelCqlSourceConnector' and 'CamelCqlSource' to plugin 'org.apache.camel.kafkaconnector.cql.CamelCqlSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,534] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.apicurio.registry.utils.converter.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'ExtJsonConverter' and 'ExtJson' to plugin 'io.apicurio.registry.utils.converter.ExtJsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'SchemalessConverter' and 'Schemaless' to plugin 'io.apicurio.registry.utils.converter.SchemalessConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,535] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,536] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,536] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,537] INFO Added alias 'ConnectRecordValueToMapTransforms' to plugin 'org.apache.camel.kafkaconnector.transforms.ConnectRecordValueToMapTransforms' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,537] INFO Added alias 'SchemaAndStructToJsonTransform' to plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,537] INFO Added alias 'SinkPojoToSchemaAndStructTransform' to plugin 'org.apache.camel.kafkaconnector.transforms.SinkPojoToSchemaAndStructTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,537] INFO Added alias 'SourcePojoToSchemaAndStructTransform' to plugin 'org.apache.camel.kafkaconnector.transforms.SourcePojoToSchemaAndStructTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,538] INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,538] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,539] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,539] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,539] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:459)
[2022-03-18 16:09:46,539] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,539] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,539] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:462)
[2022-03-18 16:09:46,558] INFO StandaloneConfig values:
access.control.allow.methods =
access.control.allow.origin =
admin.listeners = null
bootstrap.servers = [10.188.5.86:9092, 10.188.5.86:9093, 10.188.5.86:9094]
client.dns.lookup = use_all_dns_ips
config.providers = []
connector.client.config.override.policy = All
header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
key.converter = class org.apache.kafka.connect.json.JsonConverter
listeners = [http://:8083]
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
offset.flush.interval.ms = 10000
offset.flush.timeout.ms = 5000
offset.storage.file.filename = /tmp/connect.offsets
plugin.path = [/root/connectors/]
response.http.headers.config =
rest.advertised.host.name = null
rest.advertised.listener = null
rest.advertised.port = null
rest.extension.classes = []
ssl.cipher.suites = null
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
task.shutdown.graceful.timeout.ms = 5000
topic.creation.enable = true
topic.tracking.allow.reset = true
topic.tracking.enable = true
value.converter = class org.apache.kafka.connect.json.JsonConverter
(org.apache.kafka.connect.runtime.standalone.StandaloneConfig:376)
[2022-03-18 16:09:46,559] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2022-03-18 16:09:46,562] INFO AdminClientConfig values:
bootstrap.servers = [10.188.5.86:9092, 10.188.5.86:9093, 10.188.5.86:9094]
client.dns.lookup = use_all_dns_ips
client.id =
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:376)
[2022-03-18 16:09:46,626] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:46,626] INFO Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2022-03-18 16:09:46,626] INFO Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser:120)
[2022-03-18 16:09:46,627] INFO Kafka startTimeMs: 1647637786626 (org.apache.kafka.common.utils.AppInfoParser:121)
[2022-03-18 16:09:47,002] INFO Kafka cluster ID: Oxu3ww4HSvC7pYk-8nfnqA (org.apache.kafka.connect.util.ConnectUtils:65)
[2022-03-18 16:09:47,003] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-03-18 16:09:47,010] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-03-18 16:09:47,010] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-03-18 16:09:47,010] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-03-18 16:09:47,021] INFO Logging initialized @3529ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:170)
[2022-03-18 16:09:47,109] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:117)
[2022-03-18 16:09:47,110] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:188)
[2022-03-18 16:09:47,117] INFO jetty-9.4.43.v20210629; built: 2021-06-30T11:07:22.254Z; git: 526006ecfa3af7f1a27ef3a288e2bef7ea9dd7e8; jvm 1.8.0_282-b08 (org.eclipse.jetty.server.Server:375)
[2022-03-18 16:09:47,144] INFO Started http_8083@6587305a{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:331)
[2022-03-18 16:09:47,144] INFO Started @3652ms (org.eclipse.jetty.server.Server:415)
[2022-03-18 16:09:47,164] INFO Advertised URI: http://39.96.8.20:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)
[2022-03-18 16:09:47,164] INFO REST server listening at http://39.96.8.20:8083/, advertising URL http://39.96.8.20:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:203)
[2022-03-18 16:09:47,164] INFO Advertised URI: http://39.96.8.20:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)
[2022-03-18 16:09:47,165] INFO REST admin endpoints at http://39.96.8.20:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:204)
[2022-03-18 16:09:47,165] INFO Advertised URI: http://39.96.8.20:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)
[2022-03-18 16:09:47,165] INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy:44)
[2022-03-18 16:09:47,173] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49)
[2022-03-18 16:09:47,174] INFO AdminClientConfig values:
bootstrap.servers = [10.188.5.86:9092, 10.188.5.86:9093, 10.188.5.86:9094]
client.dns.lookup = use_all_dns_ips
client.id =
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:376)
[2022-03-18 16:09:47,176] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-03-18 16:09:47,177] INFO Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2022-03-18 16:09:47,177] INFO Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser:120)
[2022-03-18 16:09:47,177] INFO Kafka startTimeMs: 1647637787177 (org.apache.kafka.common.utils.AppInfoParser:121)
[2022-03-18 16:09:47,184] INFO Kafka cluster ID: Oxu3ww4HSvC7pYk-8nfnqA (org.apache.kafka.connect.util.ConnectUtils:65)
[2022-03-18 16:09:47,184] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-03-18 16:09:47,186] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-03-18 16:09:47,187] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-03-18 16:09:47,187] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-03-18 16:09:47,190] INFO Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2022-03-18 16:09:47,190] INFO Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser:120)
[2022-03-18 16:09:47,190] INFO Kafka startTimeMs: 1647637787190 (org.apache.kafka.common.utils.AppInfoParser:121)
[2022-03-18 16:09:47,315] INFO JsonConverterConfig values:
converter.type = key
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = false
(org.apache.kafka.connect.json.JsonConverterConfig:376)
[2022-03-18 16:09:47,316] INFO JsonConverterConfig values:
converter.type = value
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = false
(org.apache.kafka.connect.json.JsonConverterConfig:376)
[2022-03-18 16:09:47,324] INFO Kafka Connect standalone worker initialization took 3423ms (org.apache.kafka.connect.cli.ConnectStandalone:99)
[2022-03-18 16:09:47,324] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51)
[2022-03-18 16:09:47,325] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:98)
[2022-03-18 16:09:47,325] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:189)
[2022-03-18 16:09:47,325] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:58)
[2022-03-18 16:09:47,327] INFO Worker started (org.apache.kafka.connect.runtime.Worker:196)
[2022-03-18 16:09:47,327] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:101)
[2022-03-18 16:09:47,328] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:208)
[2022-03-18 16:09:47,363] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:225)
[2022-03-18 16:09:47,428] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:334)
[2022-03-18 16:09:47,428] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:339)
[2022-03-18 16:09:47,429] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:132)
Mar 18, 2022 4:09:47 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored.
Mar 18, 2022 4:09:47 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored.
Mar 18, 2022 4:09:47 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored.
Mar 18, 2022 4:09:47 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored.
Mar 18, 2022 4:09:47 PM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation.
WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
[2022-03-18 16:09:47,792] INFO Started o.e.j.s.ServletContextHandler@5a90265a{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:915)
[2022-03-18 16:09:47,792] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:303)
[2022-03-18 16:09:47,792] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)
[2022-03-18 16:09:47,806] INFO AbstractConfig values:
(org.apache.kafka.common.config.AbstractConfig:376)
[2022-03-18 16:09:47,813] INFO [CamelCassandra-sinkSinkConnector|worker] Creating connector CamelCassandra-sinkSinkConnector of type org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector (org.apache.kafka.connect.runtime.Worker:268)
[2022-03-18 16:09:47,814] INFO [CamelCassandra-sinkSinkConnector|worker] SinkConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.SinkConnectorConfig:376)
[2022-03-18 16:09:47,814] INFO [CamelCassandra-sinkSinkConnector|worker] EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2022-03-18 16:09:47,817] INFO [CamelCassandra-sinkSinkConnector|worker] Instantiated connector CamelCassandra-sinkSinkConnector with version 1.0.0 of type class org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector (org.apache.kafka.connect.runtime.Worker:278)
[2022-03-18 16:09:47,818] INFO [CamelCassandra-sinkSinkConnector|worker] Finished creating connector CamelCassandra-sinkSinkConnector (org.apache.kafka.connect.runtime.Worker:304)
[2022-03-18 16:09:47,819] INFO [CamelCassandra-sinkSinkConnector|worker] Connector config keys: connector.class, camel.kamelet.cassandra-sink.connectionHost, topics, tasks.max, camel.kamelet.cassandra-sink.keyspace, ---------------------------------------------------------------------------, camel.kamelet.cassandra-sink.username, camel.kamelet.cassandra-sink.query, camel.kamelet.cassandra-sink.connectionPort, name, camel.kamelet.cassandra-sink.password, value.converter, key.converter (org.apache.camel.kafkaconnector.CamelSinkConnector:41)
[2022-03-18 16:09:47,820] INFO SinkConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.SinkConnectorConfig:376)
[2022-03-18 16:09:47,820] INFO EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2022-03-18 16:09:47,821] INFO [CamelCassandra-sinkSinkConnector|worker] Setting task configurations for 1 workers. (org.apache.camel.kafkaconnector.CamelSinkConnector:52)
[2022-03-18 16:09:47,821] INFO [CamelCassandra-sinkSinkConnector|task-0] Creating task CamelCassandra-sinkSinkConnector-0 (org.apache.kafka.connect.runtime.Worker:503)
[2022-03-18 16:09:47,822] INFO [CamelCassandra-sinkSinkConnector|task-0] ConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.ConnectorConfig:376)
[2022-03-18 16:09:47,823] INFO [CamelCassandra-sinkSinkConnector|task-0] EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2022-03-18 16:09:47,823] INFO [CamelCassandra-sinkSinkConnector|task-0] TaskConfig values:
task.class = class org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkTask
(org.apache.kafka.connect.runtime.TaskConfig:376)
[2022-03-18 16:09:47,824] INFO [CamelCassandra-sinkSinkConnector|task-0] Instantiated task CamelCassandra-sinkSinkConnector-0 with version 1.0.0 of type org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkTask (org.apache.kafka.connect.runtime.Worker:518)
[2022-03-18 16:09:47,825] INFO [CamelCassandra-sinkSinkConnector|task-0] StringConverterConfig values:
converter.encoding = UTF-8
converter.type = key
(org.apache.kafka.connect.storage.StringConverterConfig:376)
[2022-03-18 16:09:47,825] INFO [CamelCassandra-sinkSinkConnector|task-0] StringConverterConfig values:
converter.encoding = UTF-8
converter.type = value
(org.apache.kafka.connect.storage.StringConverterConfig:376)
[2022-03-18 16:09:47,825] INFO [CamelCassandra-sinkSinkConnector|task-0] Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task CamelCassandra-sinkSinkConnector-0 using the connector config (org.apache.kafka.connect.runtime.Worker:533)
[2022-03-18 16:09:47,825] INFO [CamelCassandra-sinkSinkConnector|task-0] Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task CamelCassandra-sinkSinkConnector-0 using the connector config (org.apache.kafka.connect.runtime.Worker:539)
[2022-03-18 16:09:47,825] INFO [CamelCassandra-sinkSinkConnector|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task CamelCassandra-sinkSinkConnector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:544)
[2022-03-18 16:09:47,829] INFO [CamelCassandra-sinkSinkConnector|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:626)
[2022-03-18 16:09:47,829] INFO [CamelCassandra-sinkSinkConnector|task-0] SinkConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.SinkConnectorConfig:376)
[2022-03-18 16:09:47,829] INFO [CamelCassandra-sinkSinkConnector|task-0] EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
errors.log.enable = false
errors.log.include.messages = false
errors.retry.delay.max.ms = 60000
errors.retry.timeout = 0
errors.tolerance = none
header.converter = null
key.converter = class org.apache.kafka.connect.storage.StringConverter
name = CamelCassandra-sinkSinkConnector
predicates = []
tasks.max = 1
topics = [pie]
topics.regex =
transforms = []
value.converter = class org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2022-03-18 16:09:47,839] INFO [CamelCassandra-sinkSinkConnector|task-0] ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = earliest
bootstrap.servers = [10.188.5.86:9092, 10.188.5.86:9093, 10.188.5.86:9094]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = connector-consumer-CamelCassandra-sinkSinkConnector-0
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = connect-CamelCassandra-sinkSinkConnector
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
isolation.level = read_uncommitted
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
(org.apache.kafka.clients.consumer.ConsumerConfig:376)
[2022-03-18 16:09:47,873] WARN [CamelCassandra-sinkSinkConnector|task-0] The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)
[2022-03-18 16:09:47,873] INFO [CamelCassandra-sinkSinkConnector|task-0] Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser:119)
[2022-03-18 16:09:47,873] INFO [CamelCassandra-sinkSinkConnector|task-0] Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser:120)
[2022-03-18 16:09:47,873] INFO [CamelCassandra-sinkSinkConnector|task-0] Kafka startTimeMs: 1647637787873 (org.apache.kafka.common.utils.AppInfoParser:121)
[2022-03-18 16:09:47,880] INFO Created connector CamelCassandra-sinkSinkConnector (org.apache.kafka.connect.cli.ConnectStandalone:109)
[2022-03-18 16:09:47,881] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Subscribed to topic(s): pie (org.apache.kafka.clients.consumer.KafkaConsumer:966)
[2022-03-18 16:09:47,882] INFO [CamelCassandra-sinkSinkConnector|task-0] Starting CamelSinkTask connector task (org.apache.camel.kafkaconnector.CamelSinkTask:76)
[2022-03-18 16:09:47,883] INFO [CamelCassandra-sinkSinkConnector|task-0] CamelCassandrasinkSinkConnectorConfig values:
camel.aggregation.size = 10
camel.aggregation.timeout = 500
camel.beans.aggregate = null
camel.error.handler = default
camel.error.handler.max.redeliveries = 0
camel.error.handler.redelivery.delay = 1000
camel.idempotency.enabled = false
camel.idempotency.expression.header = null
camel.idempotency.expression.type = body
camel.idempotency.kafka.bootstrap.servers = localhost:9092
camel.idempotency.kafka.max.cache.size = 1000
camel.idempotency.kafka.poll.duration.ms = 100
camel.idempotency.kafka.topic = kafka_idempotent_repository
camel.idempotency.memory.dimension = 100
camel.idempotency.repository.type = memory
camel.kamelet.cassandra-sink.connectionHost = 10.66.16.10
camel.kamelet.cassandra-sink.connectionPort = 9042
camel.kamelet.cassandra-sink.consistencyLevel = ANY
camel.kamelet.cassandra-sink.keyspace = dev
camel.kamelet.cassandra-sink.password = [hidden]
camel.kamelet.cassandra-sink.preparedStatement = true
camel.kamelet.cassandra-sink.query = INSERT INTO pie (type, invented) VALUES (?,?)
camel.kamelet.cassandra-sink.username = cameldevloader
camel.map.headers = true
camel.map.properties = true
camel.remove.headers.pattern =
camel.sink.component = null
camel.sink.contentLogLevel = OFF
camel.sink.marshal = null
camel.sink.unmarshal = null
camel.sink.url = null
(org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnectorConfig:376)
[2022-03-18 16:09:47,961] INFO [CamelCassandra-sinkSinkConnector|task-0] Setting initial properties in Camel context: [[name=CamelCassandra-sinkSinkConnector, topics=pie, camel.kamelet.cassandra-sink.connectionHost=10.66.16.10, connector.class=org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkConnector, camel.kamelet.cassandra-sink.username=xxxxxxx, task.class=org.apache.camel.kafkaconnector.cassandrasink.CamelCassandrasinkSinkTask, key.converter=org.apache.kafka.connect.storage.StringConverter, camel.kamelet.cassandra-sink.keyspace=dev, value.converter=org.apache.kafka.connect.storage.StringConverter, camel.kamelet.cassandra-sink.connectionPort=9042, ---------------------------------------------------------------------------=, camel.kamelet.ckcAggregator.aggregationSize=10, camel.kamelet.cassandra-sink.password=xxxxxxx, camel.kamelet.cassandra-sink.query=INSERT INTO pie (type, invented) VALUES (?,?), tasks.max=1, camel.kamelet.ckcAggregator.aggregationTimeout=500]] (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain:298)
[2022-03-18 16:09:48,112] INFO [CamelCassandra-sinkSinkConnector|task-0] Dumping 2 routes as XML (org.apache.camel.impl.DefaultCamelContext:147)
[2022-03-18 16:09:48,607] INFO [CamelCassandra-sinkSinkConnector|task-0]
(org.apache.camel.impl.DefaultCamelContext:157)
[2022-03-18 16:09:48,607] INFO [CamelCassandra-sinkSinkConnector|task-0] Dumping 7 route templates as XML (org.apache.camel.impl.DefaultCamelContext:183)
[2022-03-18 16:09:48,624] INFO [CamelCassandra-sinkSinkConnector|task-0]
{{idempotentExpression}}
(org.apache.camel.impl.DefaultCamelContext:193)
[2022-03-18 16:09:48,638] INFO [CamelCassandra-sinkSinkConnector|task-0] Routes startup (total:2 started:2) (org.apache.camel.impl.engine.AbstractCamelContext:3111)
[2022-03-18 16:09:48,639] INFO [CamelCassandra-sinkSinkConnector|task-0] Started route1 (direct://start) (org.apache.camel.impl.engine.AbstractCamelContext:3116)
[2022-03-18 16:09:48,639] INFO [CamelCassandra-sinkSinkConnector|task-0] Started ckcRemoveHeader-1 (kamelet://source) (org.apache.camel.impl.engine.AbstractCamelContext:3116)
[2022-03-18 16:09:48,639] INFO [CamelCassandra-sinkSinkConnector|task-0] Apache Camel 3.14.0 (camel-1) started in 634ms (build:25ms init:80ms start:529ms) (org.apache.camel.impl.engine.AbstractCamelContext:3134)
[2022-03-18 16:09:48,642] INFO [CamelCassandra-sinkSinkConnector|task-0] CamelSinkTask connector task started (org.apache.camel.kafkaconnector.CamelSinkTask:157)
[2022-03-18 16:09:48,642] INFO [CamelCassandra-sinkSinkConnector|task-0] WorkerSinkTask{id=CamelCassandra-sinkSinkConnector-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:309)
[2022-03-18 16:09:48,656] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Cluster ID: Oxu3ww4HSvC7pYk-8nfnqA (org.apache.kafka.clients.Metadata:287)
[2022-03-18 16:09:48,657] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Discovered group coordinator 10.188.5.86:9093 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:849)
[2022-03-18 16:09:48,659] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:535)
[2022-03-18 16:09:48,672] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Request joining group due to: need to re-join with the given member-id (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:988)
[2022-03-18 16:09:48,672] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:535)
[2022-03-18 16:09:48,675] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Successfully joined group with generation Generation{generationId=1, memberId='connector-consumer-CamelCassandra-sinkSinkConnector-0-06ebb85a-914a-4df8-b67c-beae76d57625', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:591)
[2022-03-18 16:09:48,676] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Finished assignment for group at generation 1: {connector-consumer-CamelCassandra-sinkSinkConnector-0-06ebb85a-914a-4df8-b67c-beae76d57625=Assignment(partitions=[pie-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:626)
[2022-03-18 16:09:48,682] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Successfully synced group in generation Generation{generationId=1, memberId='connector-consumer-CamelCassandra-sinkSinkConnector-0-06ebb85a-914a-4df8-b67c-beae76d57625', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:757)
[2022-03-18 16:09:48,683] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Notifying assignor about the new Assignment(partitions=[pie-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:276)
[2022-03-18 16:09:48,684] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Adding newly assigned partitions: pie-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:288)
[2022-03-18 16:09:48,690] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Found no committed offset for partition pie-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1362)
[2022-03-18 16:09:48,698] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Resetting offset for partition pie-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.188.5.86:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398)
[2022-03-18 16:09:48,852] ERROR [CamelCassandra-sinkSinkConnector|task-0] Failed delivery for (MessageId: 00F8C8B97F6D2C0-0000000000000000 on ExchangeId: 00F8C8B97F6D2C0-0000000000000000). Exhausted after delivery attempt: 1 caught: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kamelet://cassandra-sink due to: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
Message History (complete message history is disabled)
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor Elapsed (ms)
[route1 ] [route1 ] [ ] [ 123]
...
[ckcRemoveHeader-1 ] [toD1 ] [kamelet:cassandra-sink ] [ 0]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
(org.apache.camel.processor.errorhandler.DefaultErrorHandler:205)
org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kamelet://cassandra-sink due to: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:859)
at org.apache.camel.support.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:73)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:120)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:99)
at org.apache.camel.processor.SendDynamicProcessor.resolveEndpoint(SendDynamicProcessor.java:296)
at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:157)
at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:96)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)
at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:199)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148)
at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:205)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.camel.RuntimeCamelException: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:66)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:439)
at org.apache.camel.component.kamelet.KameletComponent$1.doInit(KameletComponent.java:152)
at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
at org.apache.camel.support.service.ServiceHelper.initService(ServiceHelper.java:84)
at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1530)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1475)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1470)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1465)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:952)
... 31 more
Caused by: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:410)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:437)
... 39 more
Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route cassandra-sink-2 at: >>> To[cql://{{connectionHost}}:{{connectionPort}}/{{keyspace}}?consistencyLevel={{consistencyLevel}}&cql={{query}}&password={{?password}}&preparedStatement={{preparedStatement}}&username={{?username}}] <<< in route: Route(cassandra-sink-2)[From[kamelet://source?routeId=cassan... because of Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:240)
at org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:74)
at org.apache.camel.impl.DefaultModelReifierFactory.createRoute(DefaultModelReifierFactory.java:49)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:868)
at org.apache.camel.impl.DefaultModel.addRouteDefinitions(DefaultModel.java:185)
at org.apache.camel.impl.DefaultModel.addRouteDefinition(DefaultModel.java:191)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:415)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:303)
at org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:433)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:401)
... 40 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:850)
at org.apache.camel.support.CamelContextHelper.resolveEndpoint(CamelContextHelper.java:123)
at org.apache.camel.reifier.SendReifier.resolveEndpoint(SendReifier.java:43)
at org.apache.camel.reifier.SendReifier.createProcessor(SendReifier.java:36)
at org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:838)
at org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:579)
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:236)
... 49 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.support.DefaultComponent.validateParameters(DefaultComponent.java:299)
at org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:192)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:934)
... 56 more
[2022-03-18 16:09:48,855] WARN [CamelCassandra-sinkSinkConnector|task-0] A delivery has failed and the error reporting is NOT enabled. Records may be lost or ignored (org.apache.camel.kafkaconnector.CamelSinkTask:209)
[2022-03-18 16:09:48,855] ERROR [CamelCassandra-sinkSinkConnector|task-0] WorkerSinkTask{id=CamelCassandra-sinkSinkConnector-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.runtime.WorkerSinkTask:607)
org.apache.kafka.connect.errors.ConnectException: Exchange delivery has failed!
at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:210)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kamelet://cassandra-sink due to: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:859)
at org.apache.camel.support.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:73)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:120)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:99)
at org.apache.camel.processor.SendDynamicProcessor.resolveEndpoint(SendDynamicProcessor.java:296)
at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:157)
at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:96)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)
at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:199)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148)
at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:205)
... 11 more
Caused by: org.apache.camel.RuntimeCamelException: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:66)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:439)
at org.apache.camel.component.kamelet.KameletComponent$1.doInit(KameletComponent.java:152)
at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
at org.apache.camel.support.service.ServiceHelper.initService(ServiceHelper.java:84)
at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1530)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1475)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1470)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1465)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:952)
... 31 more
Caused by: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:410)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:437)
... 39 more
Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route cassandra-sink-2 at: >>> To[cql://{{connectionHost}}:{{connectionPort}}/{{keyspace}}?consistencyLevel={{consistencyLevel}}&cql={{query}}&password={{?password}}&preparedStatement={{preparedStatement}}&username={{?username}}] <<< in route: Route(cassandra-sink-2)[From[kamelet://source?routeId=cassan... because of Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:240)
at org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:74)
at org.apache.camel.impl.DefaultModelReifierFactory.createRoute(DefaultModelReifierFactory.java:49)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:868)
at org.apache.camel.impl.DefaultModel.addRouteDefinitions(DefaultModel.java:185)
at org.apache.camel.impl.DefaultModel.addRouteDefinition(DefaultModel.java:191)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:415)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:303)
at org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:433)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:401)
... 40 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:850)
at org.apache.camel.support.CamelContextHelper.resolveEndpoint(CamelContextHelper.java:123)
at org.apache.camel.reifier.SendReifier.resolveEndpoint(SendReifier.java:43)
at org.apache.camel.reifier.SendReifier.createProcessor(SendReifier.java:36)
at org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:838)
at org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:579)
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:236)
... 49 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.support.DefaultComponent.validateParameters(DefaultComponent.java:299)
at org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:192)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:934)
... 56 more
[2022-03-18 16:09:48,856] ERROR [CamelCassandra-sinkSinkConnector|task-0] WorkerSinkTask{id=CamelCassandra-sinkSinkConnector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:193)
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:609)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Exchange delivery has failed!
at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:210)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)
... 10 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kamelet://cassandra-sink due to: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:859)
at org.apache.camel.support.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:73)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:120)
at org.apache.camel.support.ExchangeHelper.resolveEndpoint(ExchangeHelper.java:99)
at org.apache.camel.processor.SendDynamicProcessor.resolveEndpoint(SendDynamicProcessor.java:296)
at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:157)
at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:96)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)
at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
at org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
at org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:199)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
at org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:148)
at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:205)
... 11 more
Caused by: org.apache.camel.RuntimeCamelException: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:66)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:439)
at org.apache.camel.component.kamelet.KameletComponent$1.doInit(KameletComponent.java:152)
at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
at org.apache.camel.support.service.ServiceHelper.initService(ServiceHelper.java:84)
at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1530)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1475)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1470)
at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1465)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:952)
... 31 more
Caused by: org.apache.camel.component.kamelet.KameletNotFoundException: Kamelet with id cassandra-sink not found in locations: classpath:/kamelets
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:410)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.track(KameletComponent.java:437)
... 39 more
Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route cassandra-sink-2 at: >>> To[cql://{{connectionHost}}:{{connectionPort}}/{{keyspace}}?consistencyLevel={{consistencyLevel}}&cql={{query}}&password={{?password}}&preparedStatement={{preparedStatement}}&username={{?username}}] <<< in route: Route(cassandra-sink-2)[From[kamelet://source?routeId=cassan... because of Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:240)
at org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:74)
at org.apache.camel.impl.DefaultModelReifierFactory.createRoute(DefaultModelReifierFactory.java:49)
at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:868)
at org.apache.camel.impl.DefaultModel.addRouteDefinitions(DefaultModel.java:185)
at org.apache.camel.impl.DefaultModel.addRouteDefinition(DefaultModel.java:191)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:415)
at org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:303)
at org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:433)
at org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:401)
... 40 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:968)
at org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:850)
at org.apache.camel.support.CamelContextHelper.resolveEndpoint(CamelContextHelper.java:123)
at org.apache.camel.reifier.SendReifier.resolveEndpoint(SendReifier.java:43)
at org.apache.camel.reifier.SendReifier.createProcessor(SendReifier.java:36)
at org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:838)
at org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:579)
at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:236)
... 49 more
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: cql://10.66.16.10:9042/dev?consistencyLevel=ANY&cql=INSERT+INTO+pie+%28type%2C+invented%29+VALUES+%28%3F%2C%3F%29&password=xxxxxx&preparedStatement=true&username=cameldevloader due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{preparedStatement=true}]
at org.apache.camel.support.DefaultComponent.validateParameters(DefaultComponent.java:299)
at org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:192)
at org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:934)
... 56 more
[2022-03-18 16:09:48,857] INFO [CamelCassandra-sinkSinkConnector|task-0] Stopping CamelSinkTask connector task (org.apache.camel.kafkaconnector.CamelSinkTask:221)
[2022-03-18 16:09:48,858] INFO [CamelCassandra-sinkSinkConnector|task-0] Apache Camel 3.14.0 (camel-1) shutting down (timeout:45s) (org.apache.camel.impl.engine.AbstractCamelContext:3323)
[2022-03-18 16:09:48,865] INFO [CamelCassandra-sinkSinkConnector|task-0] Routes stopped (total:2 stopped:2) (org.apache.camel.impl.engine.AbstractCamelContext:166)
[2022-03-18 16:09:48,866] INFO [CamelCassandra-sinkSinkConnector|task-0] Stopped ckcRemoveHeader-1 (kamelet://source) (org.apache.camel.impl.engine.AbstractCamelContext:166)
[2022-03-18 16:09:48,866] INFO [CamelCassandra-sinkSinkConnector|task-0] Stopped route1 (direct://start) (org.apache.camel.impl.engine.AbstractCamelContext:166)
[2022-03-18 16:09:48,867] INFO [CamelCassandra-sinkSinkConnector|task-0] Apache Camel 3.14.0 (camel-1) shutdown in 9ms (uptime:757ms) (org.apache.camel.impl.engine.AbstractCamelContext:3463)
[2022-03-18 16:09:48,867] INFO [CamelCassandra-sinkSinkConnector|task-0] CamelSinkTask connector task stopped (org.apache.camel.kafkaconnector.CamelSinkTask:235)
[2022-03-18 16:09:48,868] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Revoke previously assigned partitions pie-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:307)
[2022-03-18 16:09:48,868] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Member connector-consumer-CamelCassandra-sinkSinkConnector-0-06ebb85a-914a-4df8-b67c-beae76d57625 sending LeaveGroup request to coordinator 10.188.5.86:9093 (id: 2147483646 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1048)
[2022-03-18 16:09:48,869] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Resetting generation due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:966)
[2022-03-18 16:09:48,869] INFO [CamelCassandra-sinkSinkConnector|task-0] [Consumer clientId=connector-consumer-CamelCassandra-sinkSinkConnector-0, groupId=connect-CamelCassandra-sinkSinkConnector] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:988)
[2022-03-18 16:09:48,871] INFO [CamelCassandra-sinkSinkConnector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-03-18 16:09:48,871] INFO [CamelCassandra-sinkSinkConnector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-03-18 16:09:48,871] INFO [CamelCassandra-sinkSinkConnector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-03-18 16:09:48,872] INFO [CamelCassandra-sinkSinkConnector|task-0] App info kafka.consumer for connector-consumer-CamelCassandra-sinkSinkConnector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-03-18 16:10:35,352] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67)
[2022-03-18 16:10:35,352] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:311)
[2022-03-18 16:10:35,357] INFO Stopped http_8083@6587305a{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:381)
[2022-03-18 16:10:35,358] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:149)
[2022-03-18 16:10:35,358] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:328)
[2022-03-18 16:10:35,358] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:106)
[2022-03-18 16:10:35,359] INFO [CamelCassandra-sinkSinkConnector|task-0] Stopping task CamelCassandra-sinkSinkConnector-0 (org.apache.kafka.connect.runtime.Worker:829)
[2022-03-18 16:10:35,361] INFO [CamelCassandra-sinkSinkConnector|worker] Stopping connector CamelCassandra-sinkSinkConnector (org.apache.kafka.connect.runtime.Worker:381)
[2022-03-18 16:10:35,361] INFO [CamelCassandra-sinkSinkConnector|worker] Scheduled shutdown for WorkerConnector{id=CamelCassandra-sinkSinkConnector} (org.apache.kafka.connect.runtime.WorkerConnector:248)
[2022-03-18 16:10:35,361] INFO [CamelCassandra-sinkSinkConnector|worker] Completed shutdown for WorkerConnector{id=CamelCassandra-sinkSinkConnector} (org.apache.kafka.connect.runtime.WorkerConnector:268)
[2022-03-18 16:10:35,362] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:203)
[2022-03-18 16:10:35,362] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:66)
[2022-03-18 16:10:35,362] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-03-18 16:10:35,362] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-03-18 16:10:35,362] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-03-18 16:10:35,362] INFO App info kafka.connect for 39.96.8.20:8083 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-03-18 16:10:35,362] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:224)
[2022-03-18 16:10:35,363] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:124)
[2022-03-18 16:10:35,363] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72)