hashnao
commented
9 months ago KafkaConnect CR の生成でデグレ、user-information-connect-connect Pod から作成した Secret のパスワードが正しくないため Kafka Cluster (api-infra-kafka-bootstrap:9092) への接続エラー
```
Preparing truststore
Preparing truststore is complete
Starting Kafka Connect with configuration:
# Bootstrap servers
bootstrap.servers=api-infra-kafka-bootstrap:9092
# REST Listeners
rest.port=8083
rest.advertised.host.name=10.128.2.138
rest.advertised.port=8083
# Plugins
plugin.path=/opt/kafka/plugins
# Provided configuration
offset.storage.topic=user-information-connect-offsets
value.converter=org.apache.kafka.connect.json.JsonConverter
config.storage.topic=user-information-connect-configs
key.converter=org.apache.kafka.connect.json.JsonConverter
group.id=user-information-connect-group
status.storage.topic=user-information-connect-status
config.providers=directory
config.providers.directory.class=org.apache.kafka.common.config.provider.DirectoryConfigProvider
config.storage.replication.factor=3
offset.storage.replication.factor=3
status.storage.replication.factor=3
security.protocol=SASL_PLAINTEXT
producer.security.protocol=SASL_PLAINTEXT
consumer.security.protocol=SASL_PLAINTEXT
admin.security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-512
sasl.jaas.config=[hidden]
producer.sasl.mechanism=SCRAM-SHA-512
producer.sasl.jaas.config=[hidden]
consumer.sasl.mechanism=SCRAM-SHA-512
consumer.sasl.jaas.config=[hidden]
admin.sasl.mechanism=SCRAM-SHA-512
admin.sasl.jaas.config=[hidden]
# Additional configuration
consumer.client.rack=
+ exec /usr/bin/tini -w -e 143 -- /opt/kafka/bin/connect-distributed.sh /tmp/strimzi-connect.properties
2023-12-12 23:54:07,025 INFO Kafka Connect worker initializing ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
2023-12-12 23:54:07,027 INFO WorkerInfo values:
jvm.args = -Xms1536m, -Xmx1536m, -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, -javaagent:/opt/kafka/libs/jmx_prometheus_javaagent-0.18.0.redhat-00001.jar=9404:/opt/kafka/custom-config/metrics-config.json
jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 17.0.9, 17.0.9+9-LTS
jvm.classpath = /opt/kafka/bin/../libs/accessors-smart-2.4.9.redhat-00002.jar:/opt/kafka/bin/../libs/activation-1.1.1.redhat-5.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.6.1.redhat-00001.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.redhat-00004.jar:/opt/kafka/bin/../libs/audience-annotations-0.13.0.redhat-00002.jar:/opt/kafka/bin/../libs/commons-cli-1.4.0.redhat-00001.jar:/opt/kafka/bin/../libs/commons-lang-2.6.0.redhat-7.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.redhat-00001.jar:/opt/kafka/bin/../libs/connect-api-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-json-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-mirror-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-mirror-client-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-runtime-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/connect-transforms-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/cruise-control-metrics-reporter-2.5.123.redhat-00016.jar:/opt/kafka/bin/../libs/failureaccess-1.0.1.redhat-00004.jar:/opt/kafka/bin/../libs/gson-2.9.0.redhat-00001.jar:/opt/kafka/bin/../libs/guava-32.0.1.jre-redhat-00001.jar:/opt/kafka/bin/../libs/hk2-api-2.6.1.redhat-00001.jar:/opt/kafka/bin/../libs/hk2-locator-2.6.1.redhat-00001.jar:/opt/kafka/bin/../libs/hk2-utils-2.6.1.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-annotations-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-core-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-databind-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-dataformat-yaml-2.15.2.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-datatype-jsr310-2.15.2.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.13-2.13.5.redhat-00001.jar:/opt/kafka/bin/../libs/jaeger-client-1.8.1.redhat-00002.jar:/opt/kafka/bin/../libs/jaeger-core-1.8.1.redhat-00002.jar:/opt/kafka/bin/../libs/jaeger-thrift-1.8.1.redhat-00002.jar:/opt/kafka/bin/../libs/jaeger-tracerresolver-1.8.1.redhat-00002.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.2.redhat-00001.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.5.redhat-00004.jar:/opt/kafka/bin/../libs/jakarta.inject-2.6.1.redhat-00001.jar:/opt/kafka/bin/../libs/jakarta.validation-api-2.0.2.redhat-00002.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.redhat-00001.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.3.redhat-00003.jar:/opt/kafka/bin/../libs/javassist-3.29.2.GA-redhat-00001.jar:/opt/kafka/bin/../libs/javax.activation-api-1.2.0.redhat-00002.jar:/opt/kafka/bin/../libs/javax.annotation-api-1.3.2.redhat-00002.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.redhat-1.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.redhat-00003.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-client-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-common-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-hk2-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jersey-server-2.39.1.redhat-00001.jar:/opt/kafka/bin/../libs/jetty-client-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-http-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-io-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-security-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-server-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-util-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jetty-util-ajax-9.4.51.v20230217-redhat-00001.jar:/opt/kafka/bin/../libs/jline-3.22.0.redhat-00001.jar:/opt/kafka/bin/../libs/jmx_prometheus_javaagent-0.18.0.redhat-00001.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.redhat-00002.jar:/opt/kafka/bin/../libs/jose4j-0.9.3.redhat-00004.jar:/opt/kafka/bin/../libs/json-path-2.8.0.redhat-00002.jar:/opt/kafka/bin/../libs/json-smart-2.4.9.redhat-00002.jar:/opt/kafka/bin/../libs/jsonevent-layout-1.7.0.redhat-00002.jar:/opt/kafka/bin/../libs/jsr305-3.0.2.redhat-00015.jar:/opt/kafka/bin/../libs/kafka-agent-0.36.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-clients-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-env-var-config-provider-1.1.0.redhat-00003.jar:/opt/kafka/bin/../libs/kafka-group-coordinator-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-kubernetes-config-provider-1.1.1.redhat-00002.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-metadata-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-oauth-client-0.13.0.redhat-00011.jar:/opt/kafka/bin/../libs/kafka-oauth-common-0.13.0.redhat-00011.jar:/opt/kafka/bin/../libs/kafka-oauth-keycloak-authorizer-0.13.0.redhat-00011.jar:/opt/kafka/bin/../libs/kafka-oauth-server-0.13.0.redhat-00011.jar:/opt/kafka/bin/../libs/kafka-oauth-server-plain-0.13.0.redhat-00011.jar:/opt/kafka/bin/../libs/kafka-quotas-plugin-0.2.0.redhat-00003.jar:/opt/kafka/bin/../libs/kafka-raft-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-server-common-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-shell-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-storage-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-storage-api-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-streams-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.13-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-tools-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka-tools-api-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kafka_2.13-3.5.0.redhat-00014.jar:/opt/kafka/bin/../libs/kotlin-stdlib-1.6.20.jar:/opt/kafka/bin/../libs/kotlin-stdlib-common-1.5.31.jar:/opt/kafka/bin/../libs/kotlin-stdlib-jdk7-1.5.31.jar:/opt/kafka/bin/../libs/kotlin-stdlib-jdk8-1.5.31.jar:/opt/kafka/bin/../libs/kubernetes-client-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-client-api-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-httpclient-jdk-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-apps-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-autoscaling-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-batch-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-certificates-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-common-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-core-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-extensions-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-gatewayapi-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/kubernetes-model-resource-6.7.2.redhat-00004.jar:/opt/kafka/bin/../libs/libthrift-0.15.0.redhat-00001.jar:/opt/kafka/bin/../libs/listenablefuture-9999.0.0.empty-to-avoid-conflict-with-guava-redhat-00001.jar:/opt/kafka/bin/../libs/lz4-java-1.8.0.redhat-00005.jar:/opt/kafka/bin/../libs/maven-artifact-3.8.4.redhat-00003.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.redhat-00004.jar:/opt/kafka/bin/../libs/metrics-core-4.1.12.1-redhat-00001.jar:/opt/kafka/bin/../libs/mirror-maker-2-extensions-1.2.0.redhat-00001.jar:/opt/kafka/bin/../libs/mirror-maker-agent-0.36.0.redhat-00014.jar:/opt/kafka/bin/../libs/netty-buffer-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-codec-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-common-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-handler-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-resolver-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-transport-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-transport-classes-epoll-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-transport-native-epoll-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/netty-transport-native-unix-common-4.1.94.Final-redhat-00003.jar:/opt/kafka/bin/../libs/nimbus-jose-jwt-9.31.0.redhat-00001.jar:/opt/kafka/bin/../libs/okhttp-4.10.0.redhat-00003.jar:/opt/kafka/bin/../libs/okio-jvm-3.4.0.redhat-00001.jar:/opt/kafka/bin/../libs/opa-authorizer-1.5.1.redhat-00003.jar:/opt/kafka/bin/../libs/opentelemetry-api-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-api-logs-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-context-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-common-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-common-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-semconv-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-2.6-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-common-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-opentracing-shim-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-common-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-spi-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-logs-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-metrics-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-trace-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentelemetry-semconv-1.19.0.redhat-00002.jar:/opt/kafka/bin/../libs/opentracing-api-0.33.0.redhat-00001.jar:/opt/kafka/bin/../libs/opentracing-kafka-client-0.1.15.redhat-00006.jar:/opt/kafka/bin/../libs/opentracing-noop-0.33.0.redhat-00001.jar:/opt/kafka/bin/../libs/opentracing-tracerresolver-0.1.8.redhat-00001.jar:/opt/kafka/bin/../libs/opentracing-util-0.33.0.redhat-00001.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.3.redhat-00001.jar:/opt/kafka/bin/../libs/paranamer-2.8.0.redhat-00001.jar:/opt/kafka/bin/../libs/plexus-utils-3.3.0.redhat-00003.jar:/opt/kafka/bin/../libs/reflections-0.9.12.redhat-00003.jar:/opt/kafka/bin/../libs/reload4j-1.2.25.redhat-00001.jar:/opt/kafka/bin/../libs/rocksdbjni-7.1.2.redhat-00002.jar:/opt/kafka/bin/../libs/scala-collection-compat_2.13-2.10.0.redhat-00001.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.13-1.0.2.redhat-00001.jar:/opt/kafka/bin/../libs/scala-library-2.13.10.redhat-00001.jar:/opt/kafka/bin/../libs/scala-logging_2.13-3.9.4.redhat-00001.jar:/opt/kafka/bin/../libs/scala-reflect-2.13.10.redhat-00001.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.36.redhat-00005.jar:/opt/kafka/bin/../libs/slf4j-reload4j-1.7.36.redhat-00005.jar:/opt/kafka/bin/../libs/snakeyaml-2.0.0.redhat-00012.jar:/opt/kafka/bin/../libs/snakeyaml-engine-2.6.0.redhat-00001.jar:/opt/kafka/bin/../libs/snappy-java-1.1.10.1-redhat-00002.jar:/opt/kafka/bin/../libs/swagger-annotations-2.2.1.redhat-00001.jar:/opt/kafka/bin/../libs/tracing-agent-0.36.0.redhat-00014.jar:/opt/kafka/bin/../libs/zjsonpatch-0.3.0.redhat-00003.jar:/opt/kafka/bin/../libs/zookeeper-3.6.4.redhat-00012.jar:/opt/kafka/bin/../libs/zookeeper-jute-3.6.4.redhat-00012.jar:/opt/kafka/bin/../libs/zstd-jni-1.5.5.1-redhat-00002.jar
os.spec = Linux, amd64, 4.18.0-372.80.1.el8_6.x86_64
os.vcpus = 1
(org.apache.kafka.connect.runtime.WorkerInfo) [main]
2023-12-12 23:54:07,027 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
2023-12-12 23:54:07,039 INFO Loading plugin from: /opt/kafka/plugins/debezium-oracle-connector (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-oracle-connector/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Added plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Added plugin 'io.debezium.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Added plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,649 INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:08,650 INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,428 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@7ad041f3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,428 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,428 INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,429 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,430 INFO Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added plugin 'io.strimzi.kafka.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,431 INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,432 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,433 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,434 INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,435 INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main]
2023-12-12 23:54:13,644 INFO DistributedConfig values:
access.control.allow.methods =
access.control.allow.origin =
admin.listeners = null
auto.include.jmx.reporter = true
bootstrap.servers = [api-infra-kafka-bootstrap:9092]
client.dns.lookup = use_all_dns_ips
client.id =
config.providers = [directory]
config.storage.replication.factor = 3
config.storage.topic = user-information-connect-configs
connect.protocol = sessioned
connections.max.idle.ms = 540000
connector.client.config.override.policy = All
exactly.once.source.support = disabled
group.id = user-information-connect-group
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]
key.converter = class org.apache.kafka.connect.json.JsonConverter
listeners = [http://:8083]
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 = 3
offset.storage.topic = user-information-connect-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 = 10.128.2.138
rest.advertised.listener = null
rest.advertised.port = 8083
rest.extension.classes = []
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
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.connect.timeout.ms = null
sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-512
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
scheduled.rebalance.max.delay.ms = 300000
security.protocol = SASL_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 = 3
status.storage.topic = user-information-connect-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-12-12 23:54:13,645 INFO Creating Kafka admin client (org.apache.kafka.connect.runtime.WorkerConfig) [main]
2023-12-12 23:54:13,648 INFO AdminClientConfig values:
auto.include.jmx.reporter = true
bootstrap.servers = [api-infra-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 = [hidden]
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.connect.timeout.ms = null
sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-512
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_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-12-12 23:54:13,820 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main]
2023-12-12 23:54:13,841 INFO These configurations '[producer.sasl.jaas.config, group.id, rest.advertised.port, plugin.path, config.providers, consumer.sasl.mechanism, admin.security.protocol, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, config.providers.directory.class, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig) [main]
2023-12-12 23:54:13,841 INFO Kafka version: 3.5.0.redhat-00014 (org.apache.kafka.common.utils.AppInfoParser) [main]
2023-12-12 23:54:13,841 INFO Kafka commitId: 3c068d50e66b0dc3 (org.apache.kafka.common.utils.AppInfoParser) [main]
2023-12-12 23:54:13,841 INFO Kafka startTimeMs: 1702425253841 (org.apache.kafka.common.utils.AppInfoParser) [main]
2023-12-12 23:54:14,659 INFO [AdminClient clientId=adminclient-1] Failed authentication with api-infra-kafka-bootstrap/172.30.221.59 (channelId=-1) (Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512) (org.apache.kafka.common.network.Selector) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,660 INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,662 ERROR [AdminClient clientId=adminclient-1] Connection to node -1 (api-infra-kafka-bootstrap/172.30.221.59:9092) failed authentication due to: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512 (org.apache.kafka.clients.NetworkClient) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,663 WARN [AdminClient clientId=adminclient-1] Metadata update failed due to authentication error (org.apache.kafka.clients.admin.internals.AdminMetadataManager) [kafka-admin-client-thread | adminclient-1]
org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512
2023-12-12 23:54:14,665 INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,665 INFO [AdminClient clientId=adminclient-1] Metadata update failed (org.apache.kafka.clients.admin.internals.AdminMetadataManager) [kafka-admin-client-thread | adminclient-1]
org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited. Call: fetchMetadata
2023-12-12 23:54:14,666 INFO [AdminClient clientId=adminclient-1] Metadata update failed (org.apache.kafka.clients.admin.internals.AdminMetadataManager) [kafka-admin-client-thread | adminclient-1]
org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited. Call: fetchMetadata
2023-12-12 23:54:14,666 INFO [AdminClient clientId=adminclient-1] Timed out 2 remaining operation(s) during close. (org.apache.kafka.clients.admin.KafkaAdminClient) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,670 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,670 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,670 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1]
2023-12-12 23:54:14,670 ERROR Stopping due to error (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
org.apache.kafka.connect.errors.ConnectException: Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties.
at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:283)
at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:263)
at org.apache.kafka.connect.runtime.WorkerConfig.kafkaClusterId(WorkerConfig.java:393)
at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:124)
at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:277)
... 5 more
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512
```
次のタスクを対象とする。