Preparing truststore
Preparing truststore is complete
Starting Kafka Connect with configuration:
# Bootstrap servers
bootstrap.servers=core-kafka-bootstrap:9092
# REST Listeners
rest.port=8083
rest.advertised.host.name=100.116.230.148 
rest.advertised.port=8083
# Plugins
plugin.path=/opt/kafka/plugins
# Provided configuration
offset.storage.topic=connect-cluster-offsets
value.converter=org.apache.kafka.connect.json.JsonConverter
config.storage.topic=connect-cluster-configs
key.converter=org.apache.kafka.connect.json.JsonConverter
group.id=connect-cluster
status.storage.topic=connect-cluster-status
config.providers=file,secrets,configmaps
config.providers.configmaps.class=io.strimzi.kafka.KubernetesConfigMapConfigProvider
config.providers.file.class=org.apache.kafka.common.config.provider.FileConfigProvider
config.providers.secrets.class=io.strimzi.kafka.KubernetesSecretConfigProvider
config.storage.replication.factor=1
connector.client.config.override.policy=All
offset.storage.replication.factor=1
status.storage.replication.factor=1
security.protocol=PLAINTEXT
producer.security.protocol=PLAINTEXT
consumer.security.protocol=PLAINTEXT
admin.security.protocol=PLAINTEXT
# Additional configuration
client.rack=
+ exec /usr/bin/tini -w -e 143 -- /opt/kafka/bin/connect-distributed.sh /tmp/strimzi-connect.properties
2023-04-29 09:09:42,214 INFO WorkerInfo values: 
    jvm.args = -Xmx384m, -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=/opt/kafka, -Dlog4j.configuration=file:/opt/kafka/custom-config/log4j.properties
    jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 11.0.13, 11.0.13+8-LTS
    jvm.classpath = /opt/kafka/bin/../libs/accessors-smart-2.4.7.jar:/opt/kafka/bin/../libs/activation-1.1.1.jar:/opt/kafka/bin/../libs/annotations-13.0.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka/bin/../libs/automaton-1.11-8.jar:/opt/kafka/bin/../libs/checker-qual-3.5.0.jar:/opt/kafka/bin/../libs/commons-cli-1.4.jar:/opt/kafka/bin/../libs/commons-lang-2.6.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka/bin/../libs/connect-api-2.8.0.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-2.8.0.jar:/opt/kafka/bin/../libs/connect-file-2.8.0.jar:/opt/kafka/bin/../libs/connect-json-2.8.0.jar:/opt/kafka/bin/../libs/connect-mirror-2.8.0.jar:/opt/kafka/bin/../libs/connect-mirror-client-2.8.0.jar:/opt/kafka/bin/../libs/connect-runtime-2.8.0.jar:/opt/kafka/bin/../libs/connect-transforms-2.8.0.jar:/opt/kafka/bin/../libs/cruise-control-metrics-reporter-2.5.79.jar:/opt/kafka/bin/../libs/error_prone_annotations-2.3.4.jar:/opt/kafka/bin/../libs/failureaccess-1.0.1.jar:/opt/kafka/bin/../libs/generex-1.0.2.jar:/opt/kafka/bin/../libs/gson-2.8.6.jar:/opt/kafka/bin/../libs/guava-30.1-jre.jar:/opt/kafka/bin/../libs/hk2-api-2.6.1.jar:/opt/kafka/bin/../libs/hk2-locator-2.6.1.jar:/opt/kafka/bin/../libs/hk2-utils-2.6.1.jar:/opt/kafka/bin/../libs/j2objc-annotations-1.3.jar:/opt/kafka/bin/../libs/jackson-annotations-2.10.5.jar:/opt/kafka/bin/../libs/jackson-core-2.10.5.jar:/opt/kafka/bin/../libs/jackson-databind-2.10.5.1.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.10.5.jar:/opt/kafka/bin/../libs/jackson-dataformat-yaml-2.11.2.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.10.5.jar:/opt/kafka/bin/../libs/jackson-datatype-jsr310-2.11.2.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.10.5.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.10.5.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.10.5.jar:/opt/kafka/bin/../libs/jackson-module-paranamer-2.10.5.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.13-2.10.5.jar:/opt/kafka/bin/../libs/jaeger-client-1.6.0.jar:/opt/kafka/bin/../libs/jaeger-core-1.6.0.jar:/opt/kafka/bin/../libs/jaeger-thrift-1.6.0.jar:/opt/kafka/bin/../libs/jaeger-tracerresolver-1.6.0.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/opt/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/opt/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/opt/kafka/bin/../libs/javassist-3.27.0-GA.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka/bin/../libs/jersey-client-2.31.jar:/opt/kafka/bin/../libs/jersey-common-2.31.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.31.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.31.jar:/opt/kafka/bin/../libs/jersey-hk2-2.31.jar:/opt/kafka/bin/../libs/jersey-media-jaxb-2.31.jar:/opt/kafka/bin/../libs/jersey-server-2.31.jar:/opt/kafka/bin/../libs/jetty-client-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-http-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-io-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-security-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-server-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-util-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jetty-util-ajax-9.4.39.v20210325.jar:/opt/kafka/bin/../libs/jline-3.12.1.jar:/opt/kafka/bin/../libs/jmx_prometheus_javaagent-0.16.1.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka/bin/../libs/json-path-2.6.0.jar:/opt/kafka/bin/../libs/json-smart-2.4.7.jar:/opt/kafka/bin/../libs/jsonevent-layout-1.7.jar:/opt/kafka/bin/../libs/jsr305-3.0.2.jar:/opt/kafka/bin/../libs/kafka-agent-0.27.1.jar:/opt/kafka/bin/../libs/kafka-clients-2.8.0.jar:/opt/kafka/bin/../libs/kafka-env-var-config-provider-0.1.1.jar:/opt/kafka/bin/../libs/kafka-kubernetes-config-provider-0.1.1.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-2.8.0.jar:/opt/kafka/bin/../libs/kafka-metadata-2.8.0.jar:/opt/kafka/bin/../libs/kafka-oauth-client-0.8.1.jar:/opt/kafka/bin/../libs/kafka-oauth-common-0.8.1.jar:/opt/kafka/bin/../libs/kafka-oauth-keycloak-authorizer-0.8.1.jar:/opt/kafka/bin/../libs/kafka-oauth-server-0.8.1.jar:/opt/kafka/bin/../libs/kafka-oauth-server-plain-0.8.1.jar:/opt/kafka/bin/../libs/kafka-quotas-plugin-0.2.0.jar:/opt/kafka/bin/../libs/kafka-raft-2.8.0.jar:/opt/kafka/bin/../libs/kafka-shell-2.8.0.jar:/opt/kafka/bin/../libs/kafka-streams-2.8.0.jar:/opt/kafka/bin/../libs/kafka-streams-examples-2.8.0.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.13-2.8.0.jar:/opt/kafka/bin/../libs/kafka-streams-test-utils-2.8.0.jar:/opt/kafka/bin/../libs/kafka-tools-2.8.0.jar:/opt/kafka/bin/../libs/kafka_2.13-2.8.0-sources.jar:/opt/kafka/bin/../libs/kafka_2.13-2.8.0.jar:/opt/kafka/bin/../libs/kotlin-stdlib-1.4.10.jar:/opt/kafka/bin/../libs/kotlin-stdlib-common-1.4.0.jar:/opt/kafka/bin/../libs/kubernetes-client-5.8.0.jar:/opt/kafka/bin/../libs/kubernetes-model-apps-5.8.0.jar:/opt/kafka/bin/../libs/kubernetes-model-batch-5.8.0.jar:/opt/kafka/bin/../libs/kubernetes-model-common-5.8.0.jar:/opt/kafka/bin/../libs/kubernetes-model-core-5.8.0.jar:/opt/kafka/bin/../libs/kubernetes-model-extensions-5.8.0.jar:/opt/kafka/bin/../libs/libthrift-0.14.1.jar:/opt/kafka/bin/../libs/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/bin/../libs/log4j-1.2.17.jar:/opt/kafka/bin/../libs/logging-interceptor-3.12.12.jar:/opt/kafka/bin/../libs/lz4-java-1.7.1.jar:/opt/kafka/bin/../libs/maven-artifact-3.6.3.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka/bin/../libs/mirror-maker-2-extensions-1.0.0.jar:/opt/kafka/bin/../libs/mirror-maker-agent-0.27.1.jar:/opt/kafka/bin/../libs/netty-buffer-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-codec-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-common-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-handler-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-resolver-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-transport-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/opt/kafka/bin/../libs/nimbus-jose-jwt-9.10.jar:/opt/kafka/bin/../libs/okhttp-4.9.0.jar:/opt/kafka/bin/../libs/okio-2.8.0.jar:/opt/kafka/bin/../libs/opa-authorizer-1.3.0.jar:/opt/kafka/bin/../libs/opentracing-api-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-kafka-client-0.1.15.jar:/opt/kafka/bin/../libs/opentracing-noop-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-tracerresolver-0.1.8.jar:/opt/kafka/bin/../libs/opentracing-util-0.33.0.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/opt/kafka/bin/../libs/paranamer-2.8.jar:/opt/kafka/bin/../libs/plexus-utils-3.2.1.jar:/opt/kafka/bin/../libs/reflections-0.9.12.jar:/opt/kafka/bin/../libs/rocksdbjni-5.18.4.jar:/opt/kafka/bin/../libs/scala-collection-compat_2.13-2.3.0.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.13-0.9.1.jar:/opt/kafka/bin/../libs/scala-library-2.13.5.jar:/opt/kafka/bin/../libs/scala-logging_2.13-3.9.2.jar:/opt/kafka/bin/../libs/scala-reflect-2.13.5.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.30.jar:/opt/kafka/bin/../libs/slf4j-log4j12-1.7.30.jar:/opt/kafka/bin/../libs/snakeyaml-1.26.jar:/opt/kafka/bin/../libs/snappy-java-1.1.8.1.jar:/opt/kafka/bin/../libs/tracing-agent-0.27.1.jar:/opt/kafka/bin/../libs/zjsonpatch-0.3.0.jar:/opt/kafka/bin/../libs/zookeeper-3.5.9.jar:/opt/kafka/bin/../libs/zookeeper-jute-3.5.9.jar:/opt/kafka/bin/../libs/zstd-jni-1.4.9-1.jar
    os.spec = Linux, amd64, 5.4.0-1068-aws
    os.vcpus = 1
 (org.apache.kafka.connect.runtime.WorkerInfo) [main[]
2023-04-29 09:09:42,217 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed) [main[]
2023-04-29 09:09:42,240 INFO Loading plugin from: /opt/kafka/plugins/debezium-connector-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,233 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-connector-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,233 INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,233 INFO Added plugin 'io.debezium.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,233 INFO Added plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,233 INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.partitions.ComputePartition' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,234 INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,235 INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:43,237 INFO Loading plugin from: /opt/kafka/plugins/regatta-kafka-connect-0.0.8 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,143 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/regatta-kafka-connect-0.0.8/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,143 INFO Added plugin 'com.wandera.regatta.kafka.connect.RegattaTableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,144 INFO Loading plugin from: /opt/kafka/plugins/transforms-for-apache-kafka-connect-1.4.0 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,158 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/transforms-for-apache-kafka-connect-1.4.0/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.MakeTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ConcatFields$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ExtractTimestamp$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.FilterByFieldValue$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ExtractTopic$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ExtractTimestamp$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.Hash$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.TombstoneHandler' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ExtractTopic$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.Hash$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.FilterByFieldValue$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,159 INFO Added plugin 'io.aiven.kafka.connect.transforms.ConcatFields$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,160 INFO Loading plugin from: /opt/kafka/plugins/licenses (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,211 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/licenses/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:46,211 INFO Loading plugin from: /opt/kafka/plugins/aiven-kafka-connect-s3-2.12.0 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/aiven-kafka-connect-s3-2.12.0/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Added plugin 'io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:49,429 INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,141 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@75b84c92 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,142 INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,143 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,144 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'io.strimzi.kafka.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,145 INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,146 INFO Added aliases 'RegattaTableSinkConnector' and 'RegattaTableSink' to plugin 'com.wandera.regatta.kafka.connect.RegattaTableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,146 INFO Added aliases 'AivenKafkaConnectS3SinkConnector' and 'AivenKafkaConnectS3Sink' to plugin 'io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,146 INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,147 INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,148 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,149 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added alias 'MakeTombstone' to plugin 'io.aiven.kafka.connect.transforms.MakeTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added alias 'TombstoneHandler' to plugin 'io.aiven.kafka.connect.transforms.TombstoneHandler' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,150 INFO Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'ExtractChangedRecordState' to plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'HeaderToValue' to plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'ComputePartition' to plugin 'io.debezium.transforms.partitions.ComputePartition' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'PartitionRouting' to plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,151 INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,152 INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main[]
2023-04-29 09:09:53,237 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,044 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,116 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,116 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,130 INFO DistributedConfig values: 
    access.control.allow.methods = 
    access.control.allow.origin = 
    admin.listeners = null
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    client.dns.lookup = use_all_dns_ips
    client.id = 
    config.providers = [file, secrets, configmaps[]
    config.storage.replication.factor = 1
    config.storage.topic = connect-cluster-configs
    connect.protocol = sessioned
    connections.max.idle.ms = 540000
    connector.client.config.override.policy = All
    group.id = connect-cluster
    header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
    heartbeat.interval.ms = 3000
    inter.worker.key.generation.algorithm = HmacSHA256
    inter.worker.key.size = null
    inter.worker.key.ttl.ms = 3600000
    inter.worker.signature.algorithm = HmacSHA256
    inter.worker.verification.algorithms = [HmacSHA256[]
    internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
    internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
    key.converter = class org.apache.kafka.connect.json.JsonConverter
    listeners = null
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    offset.flush.interval.ms = 60000
    offset.flush.timeout.ms = 5000
    offset.storage.partitions = 25
    offset.storage.replication.factor = 1
    offset.storage.topic = connect-cluster-offsets
    plugin.path = [/opt/kafka/plugins]
    rebalance.timeout.ms = 60000
    receive.buffer.bytes = 32768
    reconnect.backoff.max.ms = 1000
    reconnect.backoff.ms = 50
    request.timeout.ms = 40000
    response.http.headers.config = 
    rest.advertised.host.name = 100.116.230.148
    rest.advertised.listener = null
    rest.advertised.port = 8083
    rest.extension.classes = []
    rest.host.name = null
    rest.port = 8083
    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
    scheduled.rebalance.max.delay.ms = 300000
    security.protocol = PLAINTEXT
    send.buffer.bytes = 131072
    session.timeout.ms = 10000
    socket.connection.setup.timeout.max.ms = 30000
    socket.connection.setup.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.client.auth = none
    ssl.enabled.protocols = [TLSv1.2, TLSv1.3[]
    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.3
    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
    status.storage.partitions = 5
    status.storage.replication.factor = 1
    status.storage.topic = connect-cluster-status
    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
    worker.sync.timeout.ms = 3000
    worker.unsync.backoff.ms = 300000
 (org.apache.kafka.connect.runtime.distributed.DistributedConfig) [main[]
2023-04-29 09:09:54,132 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:54,135 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,142 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,213 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,214 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:54,214 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,344 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:54,345 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:54,345 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:54,346 INFO Kafka startTimeMs: 1682759394345 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:54,911 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:54,912 INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-1]
2023-04-29 09:09:54,927 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-04-29 09:09:54,927 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-04-29 09:09:54,927 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-04-29 09:09:54,939 INFO Logging initialized @13936ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) [main[]
2023-04-29 09:09:55,026 INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,026 INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,034 INFO jetty-9.4.39.v20210325; built: 2021-03-25T14:42:11.471Z; git: 9fc7ca5a922f2a37b84ec9dbc26a5168cee7e667; jvm 11.0.13+8-LTS (org.eclipse.jetty.server.Server) [main[]
2023-04-29 09:09:55,112 INFO Started http_8083@4877919f{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector) [main[]
2023-04-29 09:09:55,112 INFO Started @14110ms (org.eclipse.jetty.server.Server) [main[]
2023-04-29 09:09:55,137 INFO Advertised URI: http://100.116.230.148:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,137 INFO REST server listening at http://100.116.230.148:8083/, advertising URL http://100.116.230.148:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,138 INFO Advertised URI: http://100.116.230.148:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,138 INFO REST admin endpoints at http://100.116.230.148:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,138 INFO Advertised URI: http://100.116.230.148:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:55,141 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,142 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,210 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,217 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,217 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,218 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [main[]
2023-04-29 09:09:55,228 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,229 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,230 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,230 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,230 INFO Kafka startTimeMs: 1682759395230 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,242 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,242 INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-2]
2023-04-29 09:09:55,311 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2]
2023-04-29 09:09:55,311 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2]
2023-04-29 09:09:55,311 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2]
2023-04-29 09:09:55,316 INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy) [main[]
2023-04-29 09:09:55,322 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,322 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,329 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,336 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,336 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,337 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,341 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,342 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,342 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,342 INFO Kafka startTimeMs: 1682759395342 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,414 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,415 INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-3]
2023-04-29 09:09:55,418 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3]
2023-04-29 09:09:55,418 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3]
2023-04-29 09:09:55,418 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3]
2023-04-29 09:09:55,421 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,421 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,421 INFO Kafka startTimeMs: 1682759395421 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,643 INFO JsonConverterConfig values: 
    converter.type = key
    decimal.format = BASE64
    schemas.cache.size = 1000
    schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig) [main[]
2023-04-29 09:09:55,644 INFO JsonConverterConfig values: 
    converter.type = value
    decimal.format = BASE64
    schemas.cache.size = 1000
    schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig) [main[]
2023-04-29 09:09:55,644 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,644 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,653 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,657 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,657 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,658 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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
2023-04-29 09:09:55,746 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,746 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,746 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,746 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,746 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,746 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,746 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,746 INFO Kafka startTimeMs: 1682759395746 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,817 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,817 INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-5]
2023-04-29 09:09:55,819 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5]
2023-04-29 09:09:55,819 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5]
2023-04-29 09:09:55,819 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5]
2023-04-29 09:09:55,823 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,823 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,828 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,833 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,833 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,834 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,837 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,837 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,838 INFO Kafka startTimeMs: 1682759395837 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,850 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,909 INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-6]
2023-04-29 09:09:55,911 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6]
2023-04-29 09:09:55,911 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6]
2023-04-29 09:09:55,911 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6]
2023-04-29 09:09:55,923 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,923 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,927 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,929 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,930 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main[]
2023-04-29 09:09:55,930 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [main[]
2023-04-29 09:09:55,932 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,932 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,932 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main[]
2023-04-29 09:09:55,933 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,933 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,933 INFO Kafka startTimeMs: 1682759395933 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:55,943 INFO Kafka cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.connect.util.ConnectUtils) [main[]
2023-04-29 09:09:55,943 INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-7]
2023-04-29 09:09:55,945 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7]
2023-04-29 09:09:55,945 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7]
2023-04-29 09:09:55,945 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7]
2023-04-29 09:09:56,015 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:56,015 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:56,015 INFO Kafka startTimeMs: 1682759396015 (org.apache.kafka.common.utils.AppInfoParser) [main[]
2023-04-29 09:09:56,019 INFO Kafka Connect distributed worker initialization took 13802ms (org.apache.kafka.connect.cli.ConnectDistributed) [main[]
2023-04-29 09:09:56,019 INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [main[]
2023-04-29 09:09:56,020 INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:56,020 INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,020 INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,020 INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,021 INFO Starting KafkaBasedLog with topic connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,021 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,026 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,029 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,029 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,030 INFO AdminClientConfig values: 
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    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, TLSv1.3[]
    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.3
    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) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,033 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,033 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,033 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,033 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,033 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,034 INFO Kafka startTimeMs: 1682759396034 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,126 INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:56,129 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,138 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,142 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,142 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,143 INFO ProducerConfig values: 
    acks = -1
    batch.size = 16384
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    buffer.memory = 33554432
    client.dns.lookup = use_all_dns_ips
    client.id = producer-1
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 2147483647
    enable.idempotence = false
    interceptor.classes = []
    internal.auto.downgrade.txn.commit = false
    key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 1
    max.request.size = 1048576
    metadata.max.age.ms = 300000
    metadata.max.idle.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    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, TLSv1.3[]
    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.3
    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
    transaction.timeout.ms = 60000
    transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,241 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,241 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,241 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,243 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,244 INFO Kafka startTimeMs: 1682759396244 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,309 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,312 INFO [Producer clientId=producer-1] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-1]
2023-04-29 09:09:56,313 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,316 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,316 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,317 INFO ConsumerConfig values: 
    allow.auto.create.topics = true
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    check.crcs = true
    client.dns.lookup = use_all_dns_ips
    client.id = consumer-connect-cluster-1
    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-cluster
    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[]
    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 = 10000
    socket.connection.setup.timeout.max.ms = 30000
    socket.connection.setup.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.3[]
    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.3
    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) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,334 INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [main[]
2023-04-29 09:09:56,334 INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [main[]
2023-04-29 09:09:56,335 INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session) [main[]
2023-04-29 09:09:56,420 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,421 INFO Kafka startTimeMs: 1682759396421 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,428 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,433 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Subscribed to partition(s): connect-cluster-offsets-0, connect-cluster-offsets-5, connect-cluster-offsets-10, connect-cluster-offsets-20, connect-cluster-offsets-15, connect-cluster-offsets-9, connect-cluster-offsets-11, connect-cluster-offsets-16, connect-cluster-offsets-4, connect-cluster-offsets-17, connect-cluster-offsets-3, connect-cluster-offsets-24, connect-cluster-offsets-23, connect-cluster-offsets-13, connect-cluster-offsets-18, connect-cluster-offsets-22, connect-cluster-offsets-2, connect-cluster-offsets-8, connect-cluster-offsets-12, connect-cluster-offsets-19, connect-cluster-offsets-14, connect-cluster-offsets-1, connect-cluster-offsets-6, connect-cluster-offsets-7, connect-cluster-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,436 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,437 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,639 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,640 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,640 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,640 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,641 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,642 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,643 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,643 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,643 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,643 INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-cluster-offsets-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,913 INFO Finished reading KafkaBasedLog for topic connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,914 INFO Started KafkaBasedLog for topic connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,914 INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,918 INFO Worker started (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,918 INFO Starting KafkaBasedLog with topic connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,925 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,928 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,931 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,931 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,932 INFO ProducerConfig values: 
    acks = -1
    batch.size = 16384
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    buffer.memory = 33554432
    client.dns.lookup = use_all_dns_ips
    client.id = producer-2
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 120000
    enable.idempotence = false
    interceptor.classes = []
    internal.auto.downgrade.txn.commit = false
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 1
    max.request.size = 1048576
    metadata.max.age.ms = 300000
    metadata.max.idle.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.max.ms = 1000
    reconnect.backoff.ms = 50
    request.timeout.ms = 30000
    retries = 0
    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, TLSv1.3[]
    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.3
    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
    transaction.timeout.ms = 60000
    transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:56,936 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,009 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,010 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,011 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,011 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,011 INFO Kafka startTimeMs: 1682759397010 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,011 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,014 INFO [Producer clientId=producer-2] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-2]
2023-04-29 09:09:57,016 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,020 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,020 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,021 INFO ConsumerConfig values: 
    allow.auto.create.topics = true
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    check.crcs = true
    client.dns.lookup = use_all_dns_ips
    client.id = consumer-connect-cluster-2
    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-cluster
    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.StringDeserializer
    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[]
    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 = 10000
    socket.connection.setup.timeout.max.ms = 30000
    socket.connection.setup.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.3[]
    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.3
    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) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,024 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,025 INFO Kafka startTimeMs: 1682759397025 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,029 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,029 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Subscribed to partition(s): connect-cluster-status-0, connect-cluster-status-1, connect-cluster-status-4, connect-cluster-status-2, connect-cluster-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,030 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,030 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,030 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,030 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,030 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,116 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-cluster-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,116 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-cluster-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,116 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-cluster-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,116 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-cluster-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,116 INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-cluster-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,510 INFO Finished reading KafkaBasedLog for topic connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,510 INFO Started KafkaBasedLog for topic connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,513 INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,513 INFO Starting KafkaBasedLog with topic connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,520 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,524 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,527 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,527 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,528 INFO ProducerConfig values: 
    acks = -1
    batch.size = 16384
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    buffer.memory = 33554432
    client.dns.lookup = use_all_dns_ips
    client.id = producer-3
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 2147483647
    enable.idempotence = false
    interceptor.classes = []
    internal.auto.downgrade.txn.commit = false
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 1
    max.request.size = 1048576
    metadata.max.age.ms = 300000
    metadata.max.idle.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    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, TLSv1.3[]
    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.3
    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
    transaction.timeout.ms = 60000
    transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,531 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,532 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,533 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,533 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,533 INFO Kafka startTimeMs: 1682759397533 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,534 INFO Configuring Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,536 INFO [Producer clientId=producer-3] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-3]
2023-04-29 09:09:57,611 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,614 INFO Closing Kubernetes ConfigMap config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,614 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,615 INFO ConsumerConfig values: 
    allow.auto.create.topics = true
    auto.commit.interval.ms = 5000
    auto.offset.reset = earliest
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    check.crcs = true
    client.dns.lookup = use_all_dns_ips
    client.id = consumer-connect-cluster-3
    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-cluster
    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.StringDeserializer
    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[]
    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 = 10000
    socket.connection.setup.timeout.max.ms = 30000
    socket.connection.setup.timeout.ms = 10000
    ssl.cipher.suites = null
    ssl.enabled.protocols = [TLSv1.2, TLSv1.3[]
    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.3
    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) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.providers.configmaps.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.providers.secrets.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'connector.client.config.override.policy' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,618 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,619 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,619 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,619 INFO Kafka startTimeMs: 1682759397619 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,622 INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,623 INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Subscribed to partition(s): connect-cluster-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,623 INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-cluster-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,630 INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting offset for partition connect-cluster-configs-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,713 INFO Successfully processed removal of connector 'mongodb-access-apps' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,719 INFO Successfully processed removal of connector 'mongodb-access-deletes-outbox' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,719 INFO Successfully processed removal of connector 'mongodb-access-app-templates' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,721 INFO Successfully processed removal of connector 'mongodb-access-apps' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,723 INFO Successfully processed removal of connector 'mongodb-access-app-templates' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,723 INFO Successfully processed removal of connector 'mongodb-access-deletes-outbox' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,723 INFO Successfully processed removal of connector 'regatta' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,724 INFO Finished reading KafkaBasedLog for topic connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,724 INFO Started KafkaBasedLog for topic connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,724 INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,724 INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
Apr 29, 2023 9:09:57 AM 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. 
Apr 29, 2023 9:09:57 AM 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. 
2023-04-29 09:09:57,815 INFO [Worker clientId=connect-1, groupId=connect-cluster] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1[]
Apr 29, 2023 9:09:57 AM 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. 
Apr 29, 2023 9:09:57 AM 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. 
2023-04-29 09:09:57,815 INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,817 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1[]
2023-04-29 09:09:57,839 INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1[]
Apr 29, 2023 9:09:58 AM 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.
2023-04-29 09:09:58,224 INFO Started o.e.j.s.ServletContextHandler@53982523{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [main[]
2023-04-29 09:09:58,225 INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [main[]
2023-04-29 09:09:58,225 INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [main[]
2023-04-29 09:10:00,842 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=17, memberId='connect-1-9cd62683-6367-4ea6-837b-212c452d1483', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,860 INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=17, memberId='connect-1-9cd62683-6367-4ea6-837b-212c452d1483', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,861 INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 17 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-9cd62683-6367-4ea6-837b-212c452d1483', leaderUrl='http://100.116.230.148:8083/', offset=142, connectorIds=[mongodb-access-apps[], taskIds=[mongodb-access-apps-0[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,862 WARN [Worker clientId=connect-1, groupId=connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,862 INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset -1 is behind group assignment 142, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,866 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 142 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,866 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 142 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:00,868 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting task mongodb-access-apps-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:00,868 INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connector mongodb-access-apps (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:00,870 INFO Retrieving configuration from Secret mongo-debezium in namespace jkaspar (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:00,870 INFO Retrieving configuration from Secret mongo-debezium in namespace jkaspar (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:01,617 INFO Retrieving configuration from Secret mongo-debezium in namespace jkaspar (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,621 INFO Creating connector mongodb-access-apps of type io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:01,626 INFO Creating task mongodb-access-apps-0 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,626 INFO SourceConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    topic.creation.groups = []
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:01,631 INFO ConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,710 INFO EnrichedConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    topic.creation.groups = []
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    transforms.composeKey.delimiter = #
    transforms.composeKey.field.names = [customerId, _id[]
    transforms.composeKey.field.replace.missing = 
    transforms.composeKey.negate = false
    transforms.composeKey.output.field.name = key
    transforms.composeKey.predicate = 
    transforms.composeKey.type = class io.aiven.kafka.connect.transforms.ConcatFields$Key
    transforms.extractKey.field = key
    transforms.extractKey.negate = false
    transforms.extractKey.predicate = 
    transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
    transforms.removeField.blacklist = [_class[]
    transforms.removeField.exclude = []
    transforms.removeField.include = []
    transforms.removeField.negate = false
    transforms.removeField.predicate = 
    transforms.removeField.renames = []
    transforms.removeField.type = class org.apache.kafka.connect.transforms.ReplaceField$Value
    transforms.removeField.whitelist = null
    transforms.renameId.blacklist = null
    transforms.renameId.exclude = []
    transforms.renameId.include = []
    transforms.renameId.negate = false
    transforms.renameId.predicate = 
    transforms.renameId.renames = [_id:id[]
    transforms.renameId.type = class org.apache.kafka.connect.transforms.ReplaceField$Value
    transforms.renameId.whitelist = null
    transforms.setTopic.negate = false
    transforms.setTopic.predicate = 
    transforms.setTopic.regex = .*
    transforms.setTopic.replacement = access-apps
    transforms.setTopic.type = class org.apache.kafka.connect.transforms.RegexRouter
    transforms.unwrap.array.encoding = array
    transforms.unwrap.flatten.struct = false
    transforms.unwrap.flatten.struct.delimiter = _
    transforms.unwrap.negate = false
    transforms.unwrap.predicate = 
    transforms.unwrap.type = class io.debezium.connector.mongodb.transforms.ExtractNewDocumentState
    transforms.valueToKey.fields = [customerId, _id[]
    transforms.valueToKey.negate = false
    transforms.valueToKey.predicate = 
    transforms.valueToKey.negate = false
    transforms.valueToKey.predicate = 
    transforms.valueToKey.type = class org.apache.kafka.connect.transforms.ValueToKey
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,723 INFO Instantiated connector mongodb-access-apps with version 2.2.0.Final of type class io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:01,724 INFO Finished creating connector mongodb-access-apps (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1[]
2023-04-29 09:10:01,725 INFO TaskConfig values: 
    task.class = class io.debezium.connector.mongodb.MongoDbConnectorTask
 (org.apache.kafka.connect.runtime.TaskConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,727 INFO Instantiated task mongodb-access-apps-0 with version 2.2.0.Final of type io.debezium.connector.mongodb.MongoDbConnectorTask (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,728 INFO StringConverterConfig values: 
    converter.encoding = UTF8
    converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,729 INFO JsonConverterConfig values: 
    converter.type = value
    decimal.format = BASE64
    schemas.cache.size = 1000
    schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,729 INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task mongodb-access-apps-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,729 INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task mongodb-access-apps-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,729 INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task mongodb-access-apps-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,734 INFO SourceConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    topic.creation.groups = []
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,736 INFO EnrichedConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    topic.creation.groups = []
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    transforms.composeKey.delimiter = #
    transforms.composeKey.field.names = [customerId, _id[]
    transforms.composeKey.field.replace.missing = 
    transforms.composeKey.negate = false
    transforms.composeKey.output.field.name = key
    transforms.composeKey.predicate = 
    transforms.composeKey.type = class io.aiven.kafka.connect.transforms.ConcatFields$Key
    transforms.extractKey.field = key
    transforms.extractKey.negate = false
    transforms.extractKey.predicate = 
    transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
    transforms.removeField.blacklist = [_class[]
    transforms.removeField.exclude = []
    transforms.removeField.include = []
    transforms.removeField.negate = false
    transforms.removeField.predicate = 
    transforms.removeField.renames = []
    transforms.removeField.type = class org.apache.kafka.connect.transforms.ReplaceField$Value
    transforms.removeField.whitelist = null
    transforms.renameId.blacklist = null
    transforms.renameId.exclude = []
    transforms.renameId.include = []
    transforms.renameId.negate = false
    transforms.renameId.predicate = 
    transforms.renameId.renames = [_id:id[]
    transforms.renameId.type = class org.apache.kafka.connect.transforms.ReplaceField$Value
    transforms.renameId.whitelist = null
    transforms.setTopic.negate = false
    transforms.setTopic.predicate = 
    transforms.setTopic.regex = .*
    transforms.setTopic.replacement = access-apps
    transforms.setTopic.type = class org.apache.kafka.connect.transforms.RegexRouter
    transforms.unwrap.array.encoding = array
    transforms.unwrap.flatten.struct = false
    transforms.unwrap.flatten.struct.delimiter = _
    transforms.unwrap.negate = false
    transforms.unwrap.predicate = 
    transforms.unwrap.type = class io.debezium.connector.mongodb.transforms.ExtractNewDocumentState
    transforms.valueToKey.fields = [customerId, _id[]
    transforms.valueToKey.negate = false
    transforms.valueToKey.predicate = 
    transforms.valueToKey.type = class org.apache.kafka.connect.transforms.ValueToKey
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,826 INFO ConcatFieldsConfig values: 
    delimiter = #
    field.names = [customerId, _id[]
    field.replace.missing = 
    output.field.name = key
 (io.aiven.kafka.connect.transforms.ConcatFieldsConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,827 WARN Configuration key blacklist is deprecated and may be removed in the future.  Please update your configuration to use exclude instead. (org.apache.kafka.common.utils.ConfigUtils) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,827 INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{io.debezium.connector.mongodb.transforms.ExtractNewDocumentState, org.apache.kafka.connect.transforms.ValueToKey, io.aiven.kafka.connect.transforms.ConcatFields$Key, org.apache.kafka.connect.transforms.ExtractField$Key, org.apache.kafka.connect.transforms.ReplaceField$Value, org.apache.kafka.connect.transforms.ReplaceField$Value, org.apache.kafka.connect.transforms.RegexRouter} (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,830 INFO ProducerConfig values: 
    acks = -1
    batch.size = 16384
    bootstrap.servers = [core-kafka-bootstrap:9092[]
    buffer.memory = 33554432
    client.dns.lookup = use_all_dns_ips
    client.id = connector-producer-mongodb-access-apps-0
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 2147483647
    enable.idempotence = false
    interceptor.classes = []
    internal.auto.downgrade.txn.commit = false
    key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
    linger.ms = 0
    max.block.ms = 9223372036854775807
    max.in.flight.requests.per.connection = 1
    max.request.size = 1048576
    metadata.max.age.ms = 300000
    metadata.max.idle.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.max.ms = 1000
    reconnect.backoff.ms = 50
    request.timeout.ms = 2147483647
    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, TLSv1.3[]
    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.3
    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
    transaction.timeout.ms = 60000
    transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,835 WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,835 WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,835 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,835 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,835 INFO Kafka startTimeMs: 1682759401835 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2[]
2023-04-29 09:10:01,839 INFO [Producer clientId=connector-producer-mongodb-access-apps-0] Cluster ID: fPJXUKKnT4-xDV3MUsiTYA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connector-producer-mongodb-access-apps-0]
2023-04-29 09:10:01,914 INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:01,918 INFO Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [connector-thread-mongodb-access-apps[]
2023-04-29 09:10:01,933 INFO Starting MongoDbConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:01,939 INFO [Worker clientId=connect-1, groupId=connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - connect-cluster-configs[]
2023-04-29 09:10:02,009 INFO    connector.class = io.debezium.connector.mongodb.MongoDbConnector (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    errors.log.include.messages = true (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    collection.include.list = jkaspar_default.apps (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.connection.string = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.password = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms = unwrap,valueToKey,composeKey,extractKey,renameId,removeField,setTopic (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    capture.mode = change_streams_update_full (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.extractKey.type = org.apache.kafka.connect.transforms.ExtractField$Key (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.ssl.enabled = true (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.composeKey.output.field.name = key (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    tombstones.on.delete = false (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.valueToKey.type = org.apache.kafka.connect.transforms.ValueToKey (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    topic.prefix = mongodb-access-apps-2 (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.members.auto.discover = true (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.task.id = 0 (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.renameId.type = org.apache.kafka.connect.transforms.ReplaceField$Value (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.composeKey.field.names = customerId,_id (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.authsource = admin (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.renameId.renames = _id:id (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.unwrap.type = io.debezium.connector.mongodb.transforms.ExtractNewDocumentState (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    errors.log.enable = true (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    key.converter = org.apache.kafka.connect.storage.StringConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.setTopic.replacement = access-apps (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.composeKey.delimiter = # (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.setTopic.type = org.apache.kafka.connect.transforms.RegexRouter (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.extractKey.field = key (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    mongodb.user = debezium_fi (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.setTopic.regex = .* (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.valueToKey.fields = customerId,_id (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    internal.mongodb.replica.sets = mongodb://foo:27017/?replicaSet=rs27017 (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    task.class = io.debezium.connector.mongodb.MongoDbConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.removeField.type = org.apache.kafka.connect.transforms.ReplaceField$Value (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    name = mongodb-access-apps (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    errors.tolerance = all (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.removeField.blacklist = _class (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    transforms.composeKey.type = io.aiven.kafka.connect.transforms.ConcatFields$Key (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    snapshot.mode = initial (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO    database.include.list = jkaspar_default (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO WorkerSourceTask{id=mongodb-access-apps-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,010 INFO Attempting to start task (io.debezium.connector.common.BaseSourceTask) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,025 INFO Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [task-thread-mongodb-access-apps-0[]
2023-04-29 09:10:02,125 INFO Starting MongoDB connector and discovering replica set(s) at mongodb://foo:27017/?replicaSet=rs27017 (io.debezium.connector.mongodb.MongoDbConnector) [connector-thread-mongodb-access-apps[]
2023-04-29 09:10:02,126 INFO Requested thread factory for connector MongoDbConnector, id = mongodb-access-apps-2 named = replica-set-monitor (io.debezium.util.Threads) [connector-thread-mongodb-access-apps[]
2023-04-29 09:10:02,131 INFO Creating thread debezium-mongodbconnector-mongodb-access-apps-2-replica-set-monitor (io.debezium.util.Threads) [connector-thread-mongodb-access-apps[]
2023-04-29 09:10:02,132 INFO Successfully started MongoDB connector, and continuing to discover changes in replica set(s) at mongodb://foo:27017/?replicaSet=rs27017 (io.debezium.connector.mongodb.MongoDbConnector) [connector-thread-mongodb-access-apps[]
2023-04-29 09:10:02,209 INFO Retrieving configuration from Secret mongo-debezium in namespace jkaspar (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1[]
2023-04-29 09:10:02,217 INFO SourceConnectorConfig values: 
    config.action.reload = restart
    connector.class = io.debezium.connector.mongodb.MongoDbConnector
    errors.log.enable = true
    errors.log.include.messages = true
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = all
    header.converter = null
    key.converter = class org.apache.kafka.connect.storage.StringConverter
    name = mongodb-access-apps
    predicates = []
    tasks.max = 1
    topic.creation.groups = []
    transforms = [unwrap, valueToKey, composeKey, extractKey, renameId, removeField, setTopic[]
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-1-1[]
2023-04-29 09:11:01,914 INFO WorkerSourceTask{id=mongodb-access-apps-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:11:01,914 WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:11:02,149 INFO [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-9cd62683-6367-4ea6-837b-212c452d1483 sending LeaveGroup request to coordinator core-kafka-0.core-kafka-brokers.jkaspar.svc:9092 (id: 2147483647 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [kafka-coordinator-heartbeat-thread | connect-cluster]
2023-04-29 09:12:01,915 INFO WorkerSourceTask{id=mongodb-access-apps-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:12:01,915 WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:13:01,916 INFO WorkerSourceTask{id=mongodb-access-apps-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:13:01,916 WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:14:01,916 INFO WorkerSourceTask{id=mongodb-access-apps-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:14:01,916 WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:15:01,916 INFO WorkerSourceTask{id=mongodb-access-apps-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1[]
2023-04-29 09:15:01,916 WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask) [SourceTaskOffsetCommitter-1[]