Preparing truststore Preparing truststore is complete Starting Kafka Connect with configuration: # Bootstrap servers bootstrap.servers=lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 # REST Listeners rest.port=8083 rest.advertised.host.name=10.130.5.175 rest.advertised.port=8083 # Plugins plugin.path=/opt/kafka/plugins # Provided configuration offset.storage.topic=dbz-caac124639bd54b45a2636390fe0c49a8-offset value.converter=org.apache.kafka.connect.json.JsonConverter config.storage.topic=dbz-caac124639bd54b45a2636390fe0c49a8-config key.converter=org.apache.kafka.connect.json.JsonConverter group.id=dbz-caac124639bd54b45a2636390fe0c49a8 status.storage.topic=dbz-caac124639bd54b45a2636390fe0c49a8-status config.providers=file config.providers.file.class=org.apache.kafka.common.config.provider.FileConfigProvider config.storage.replication.factor=2 consumer.request.timeout.ms=20000 consumer.retry.backoff.ms=500 key.converter.schemas.enable=true offset.storage.replication.factor=2 producer.compression.type=lz4 producer.request.timeout.ms=20000 producer.retry.backoff.ms=500 request.timeout.ms=20000 retry.backoff.ms=500 status.storage.replication.factor=2 value.converter.schemas.enable=true security.protocol=SASL_SSL producer.security.protocol=SASL_SSL consumer.security.protocol=SASL_SSL admin.security.protocol=SASL_SSL sasl.mechanism=PLAIN sasl.jaas.config=[hidden] producer.sasl.mechanism=PLAIN producer.sasl.jaas.config=[hidden] consumer.sasl.mechanism=PLAIN consumer.sasl.jaas.config=[hidden] admin.sasl.mechanism=PLAIN admin.sasl.jaas.config=[hidden] # Additional configuration client.rack= 2021-07-21 12:34:04,839 INFO WorkerInfo values: jvm.args = -Xms128M, -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.11, 11.0.11+9-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/commons-math3-3.6.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.57.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.0-jre.jar:/opt/kafka/bin/../libs/hamcrest-core-1.3.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.12-2.10.5.jar:/opt/kafka/bin/../libs/jaeger-client-1.3.2.jar:/opt/kafka/bin/../libs/jaeger-core-1.3.2.jar:/opt/kafka/bin/../libs/jaeger-thrift-1.3.2.jar:/opt/kafka/bin/../libs/jaeger-tracerresolver-1.3.2.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.15.0.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/junit-4.13.2.jar:/opt/kafka/bin/../libs/kafka-agent-0.24.0.jar:/opt/kafka/bin/../libs/kafka-clients-2.8.0.jar:/opt/kafka/bin/../libs/kafka-kubernetes-config-provider-0.1.0.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.1.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.12-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.12-2.8.0-sources.jar:/opt/kafka/bin/../libs/kafka_2.12-2.8.0.jar:/opt/kafka/bin/../libs/kotlin-stdlib-1.3.50.jar:/opt/kafka/bin/../libs/kotlin-stdlib-common-1.3.50.jar:/opt/kafka/bin/../libs/kubernetes-client-5.4.0.jar:/opt/kafka/bin/../libs/kubernetes-model-core-5.4.0.jar:/opt/kafka/bin/../libs/libthrift-0.13.0.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-0.1.0.jar:/opt/kafka/bin/../libs/mirror-maker-agent-0.24.0.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.2.2.jar:/opt/kafka/bin/../libs/okio-2.2.2.jar:/opt/kafka/bin/../libs/opa-authorizer-0.4.2.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.12-2.3.0.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.12-0.9.1.jar:/opt/kafka/bin/../libs/scala-library-2.12.13.jar:/opt/kafka/bin/../libs/scala-logging_2.12-3.9.2.jar:/opt/kafka/bin/../libs/scala-reflect-2.12.13.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.24.0.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, 4.18.0-240.22.1.el8_3.x86_64 os.vcpus = 1 (org.apache.kafka.connect.runtime.WorkerInfo) [main] 2021-07-21 12:34:04,845 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed) [main] 2021-07-21 12:34:04,885 INFO Loading plugin from: /opt/kafka/plugins/debezium-connector (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,894 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-connector/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,894 INFO Added plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,894 INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:05,895 INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@75b84c92 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,608 INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,609 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,610 INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,611 INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,611 INFO Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,611 INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,611 INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,612 INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,613 INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,614 INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,615 INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,616 INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-07-21 12:34:09,688 INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] client.dns.lookup = use_all_dns_ips client.id = config.providers = [file] config.storage.replication.factor = 2 config.storage.topic = dbz-caac124639bd54b45a2636390fe0c49a8-config connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = dbz-caac124639bd54b45a2636390fe0c49a8 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 = 2 offset.storage.topic = dbz-caac124639bd54b45a2636390fe0c49a8-offset 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 = 20000 response.http.headers.config = rest.advertised.host.name = 10.130.5.175 rest.advertised.listener = null rest.advertised.port = 8083 rest.extension.classes = [] rest.host.name = null rest.port = 8083 retry.backoff.ms = 500 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.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 = PLAIN scheduled.rebalance.max.delay.ms = 300000 security.protocol = SASL_SSL 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 = 2 status.storage.topic = dbz-caac124639bd54b45a2636390fe0c49a8-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] 2021-07-21 12:34:09,697 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:09,710 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:09,909 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:10,279 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,280 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:10,281 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:10,281 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:10,281 INFO Kafka startTimeMs: 1626870850281 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:12,058 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:12,060 INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-1] 2021-07-21 12:34:12,074 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2021-07-21 12:34:12,075 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2021-07-21 12:34:12,075 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2021-07-21 12:34:12,093 INFO Logging initialized @8488ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) [main] 2021-07-21 12:34:12,157 INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,158 INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,165 INFO jetty-9.4.39.v20210325; built: 2021-03-25T14:42:11.471Z; git: 9fc7ca5a922f2a37b84ec9dbc26a5168cee7e667; jvm 11.0.11+9-LTS (org.eclipse.jetty.server.Server) [main] 2021-07-21 12:34:12,203 INFO Started http_8083@100c567f{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector) [main] 2021-07-21 12:34:12,203 INFO Started @8599ms (org.eclipse.jetty.server.Server) [main] 2021-07-21 12:34:12,229 INFO Advertised URI: http://10.130.5.175:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,230 INFO REST server listening at http://10.130.5.175:8083/, advertising URL http://10.130.5.175:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,230 INFO Advertised URI: http://10.130.5.175:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,230 INFO REST admin endpoints at http://10.130.5.175:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,230 INFO Advertised URI: http://10.130.5.175:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:12,233 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:12,234 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:12,239 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:12,247 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,247 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:12,248 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:12,248 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:12,248 INFO Kafka startTimeMs: 1626870852248 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:13,434 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:13,435 INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-2] 2021-07-21 12:34:13,440 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2] 2021-07-21 12:34:13,440 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2] 2021-07-21 12:34:13,440 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-2] 2021-07-21 12:34:13,451 INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy) [main] 2021-07-21 12:34:13,458 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:13,458 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:13,460 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,464 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:13,465 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:13,465 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:13,465 INFO Kafka startTimeMs: 1626870853465 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,542 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:14,543 INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-3] 2021-07-21 12:34:14,547 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3] 2021-07-21 12:34:14,547 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3] 2021-07-21 12:34:14,547 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-3] 2021-07-21 12:34:14,555 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,555 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,555 INFO Kafka startTimeMs: 1626870854555 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,731 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2021-07-21 12:34:14,749 INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2021-07-21 12:34:14,749 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:14,749 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:14,756 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:14,764 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,764 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,765 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:14,770 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,770 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:14,770 INFO Kafka startTimeMs: 1626870854770 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:15,824 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:15,824 INFO App info kafka.admin.client for adminclient-4 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-4] 2021-07-21 12:34:15,827 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-4] 2021-07-21 12:34:15,827 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-4] 2021-07-21 12:34:15,827 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-4] 2021-07-21 12:34:15,836 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:15,837 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:15,838 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:15,841 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,841 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,841 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,841 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:15,842 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:15,842 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:15,842 INFO Kafka startTimeMs: 1626870855842 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:16,905 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:16,906 INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-5] 2021-07-21 12:34:16,909 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5] 2021-07-21 12:34:16,911 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5] 2021-07-21 12:34:16,911 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-5] 2021-07-21 12:34:16,916 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:16,916 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:16,918 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:16,921 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:16,921 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:16,921 INFO Kafka startTimeMs: 1626870856921 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:17,959 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:17,959 INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-6] 2021-07-21 12:34:17,963 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6] 2021-07-21 12:34:17,963 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6] 2021-07-21 12:34:17,963 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-6] 2021-07-21 12:34:17,984 INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:17,986 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:17,989 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:17,993 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,993 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'config.providers.file.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,994 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2021-07-21 12:34:17,995 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:17,995 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:17,995 INFO Kafka startTimeMs: 1626870857995 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:19,066 INFO Kafka cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.connect.util.ConnectUtils) [main] 2021-07-21 12:34:19,067 INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-7] 2021-07-21 12:34:19,069 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7] 2021-07-21 12:34:19,069 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7] 2021-07-21 12:34:19,069 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-7] 2021-07-21 12:34:19,074 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2021-07-21 12:34:19,098 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:19,098 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:19,098 INFO Kafka startTimeMs: 1626870859098 (org.apache.kafka.common.utils.AppInfoParser) [main] 2021-07-21 12:34:19,101 INFO Kafka Connect distributed worker initialization took 14256ms (org.apache.kafka.connect.cli.ConnectDistributed) [main] 2021-07-21 12:34:19,101 INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [main] 2021-07-21 12:34:19,103 INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:19,103 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,103 INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,103 INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,103 INFO Starting KafkaBasedLog with topic dbz-caac124639bd54b45a2636390fe0c49a8-offset (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,104 INFO AdminClientConfig values: bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:19,117 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 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] 2021-07-21 12:34:19,117 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] 2021-07-21 12:34:19,117 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] 2021-07-21 12:34:19,117 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,117 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 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] 2021-07-21 12:34:19,118 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] 2021-07-21 12:34:19,118 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 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] 2021-07-21 12:34:19,118 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 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] 2021-07-21 12:34:19,118 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,118 INFO Kafka startTimeMs: 1626870859118 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:19,152 INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:19,249 INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [main] 2021-07-21 12:34:19,249 INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [main] 2021-07-21 12:34:19,250 INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session) [main] Jul 21, 2021 12:34:19 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. Jul 21, 2021 12:34:19 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. Jul 21, 2021 12:34:19 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. Jul 21, 2021 12:34:19 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. Jul 21, 2021 12:34:19 PM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. 2021-07-21 12:34:19,914 INFO Started o.e.j.s.ServletContextHandler@5de6cf3a{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [main] 2021-07-21 12:34:19,914 INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2021-07-21 12:34:19,914 INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [main] 2021-07-21 12:34:20,306 INFO Created topic (name=dbz-caac124639bd54b45a2636390fe0c49a8-offset, numPartitions=25, replicationFactor=2, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,312 INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:20,333 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 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] 2021-07-21 12:34:20,333 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] 2021-07-21 12:34:20,333 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] 2021-07-21 12:34:20,333 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,333 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,337 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 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] 2021-07-21 12:34:20,338 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] 2021-07-21 12:34:20,338 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 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] 2021-07-21 12:34:20,338 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 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] 2021-07-21 12:34:20,338 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,338 INFO Kafka startTimeMs: 1626870860338 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,346 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-dbz-caac124639bd54b45a2636390fe0c49a8-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 = dbz-caac124639bd54b45a2636390fe0c49a8 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 = 20000 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:20,382 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 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] 2021-07-21 12:34:20,382 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] 2021-07-21 12:34:20,382 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] 2021-07-21 12:34:20,382 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,382 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 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] 2021-07-21 12:34:20,410 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] 2021-07-21 12:34:20,410 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 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] 2021-07-21 12:34:20,410 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 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] 2021-07-21 12:34:20,410 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,410 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,414 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,414 INFO Kafka startTimeMs: 1626870860410 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,871 INFO [Producer clientId=producer-1] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-1] 2021-07-21 12:34:20,935 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,942 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Subscribed to partition(s): dbz-caac124639bd54b45a2636390fe0c49a8-offset-0, dbz-caac124639bd54b45a2636390fe0c49a8-offset-5, dbz-caac124639bd54b45a2636390fe0c49a8-offset-10, dbz-caac124639bd54b45a2636390fe0c49a8-offset-20, dbz-caac124639bd54b45a2636390fe0c49a8-offset-15, dbz-caac124639bd54b45a2636390fe0c49a8-offset-9, dbz-caac124639bd54b45a2636390fe0c49a8-offset-11, dbz-caac124639bd54b45a2636390fe0c49a8-offset-4, dbz-caac124639bd54b45a2636390fe0c49a8-offset-16, dbz-caac124639bd54b45a2636390fe0c49a8-offset-17, dbz-caac124639bd54b45a2636390fe0c49a8-offset-3, dbz-caac124639bd54b45a2636390fe0c49a8-offset-24, dbz-caac124639bd54b45a2636390fe0c49a8-offset-23, dbz-caac124639bd54b45a2636390fe0c49a8-offset-13, dbz-caac124639bd54b45a2636390fe0c49a8-offset-18, dbz-caac124639bd54b45a2636390fe0c49a8-offset-22, dbz-caac124639bd54b45a2636390fe0c49a8-offset-2, dbz-caac124639bd54b45a2636390fe0c49a8-offset-8, dbz-caac124639bd54b45a2636390fe0c49a8-offset-12, dbz-caac124639bd54b45a2636390fe0c49a8-offset-19, dbz-caac124639bd54b45a2636390fe0c49a8-offset-14, dbz-caac124639bd54b45a2636390fe0c49a8-offset-1, dbz-caac124639bd54b45a2636390fe0c49a8-offset-6, dbz-caac124639bd54b45a2636390fe0c49a8-offset-7, dbz-caac124639bd54b45a2636390fe0c49a8-offset-21 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,944 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:20,945 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,206 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,207 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,662 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,662 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,662 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,662 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,662 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,663 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,663 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,663 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,664 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-offset-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,667 INFO Finished reading KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-offset (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,667 INFO Started KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-offset (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,667 INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,678 INFO Worker started (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,678 INFO Starting KafkaBasedLog with topic dbz-caac124639bd54b45a2636390fe0c49a8-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,784 INFO Created topic (name=dbz-caac124639bd54b45a2636390fe0c49a8-status, numPartitions=5, replicationFactor=2, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,785 INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 0 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:22,789 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 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] 2021-07-21 12:34:22,789 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,789 INFO Kafka startTimeMs: 1626870862789 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,790 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-dbz-caac124639bd54b45a2636390fe0c49a8-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 = dbz-caac124639bd54b45a2636390fe0c49a8 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 = 20000 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:22,794 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 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] 2021-07-21 12:34:22,794 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:22,794 INFO Kafka startTimeMs: 1626870862794 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,307 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,307 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Subscribed to partition(s): dbz-caac124639bd54b45a2636390fe0c49a8-status-0, dbz-caac124639bd54b45a2636390fe0c49a8-status-4, dbz-caac124639bd54b45a2636390fe0c49a8-status-1, dbz-caac124639bd54b45a2636390fe0c49a8-status-2, dbz-caac124639bd54b45a2636390fe0c49a8-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,307 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,308 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,308 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,308 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,308 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:23,322 INFO [Producer clientId=producer-2] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-2] 2021-07-21 12:34:24,032 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 0 rack: us-east-1c)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,473 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,473 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,473 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,474 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-2, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-2-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2 rack: us-east-1a)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,474 INFO Finished reading KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,474 INFO Started KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,474 INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,474 INFO Starting KafkaBasedLog with topic dbz-caac124639bd54b45a2636390fe0c49a8-config (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,564 INFO Created topic (name=dbz-caac124639bd54b45a2636390fe0c49a8-config, numPartitions=1, replicationFactor=2, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,565 INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:24,568 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'client.rack' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 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] 2021-07-21 12:34:24,568 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,568 INFO Kafka startTimeMs: 1626870864568 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,569 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-dbz-caac124639bd54b45a2636390fe0c49a8-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 = dbz-caac124639bd54b45a2636390fe0c49a8 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 = 20000 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:34:24,573 WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'producer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'config.providers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'consumer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'admin.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'producer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 WARN The configuration 'producer.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'admin.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'consumer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'consumer.request.timeout.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'consumer.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 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] 2021-07-21 12:34:24,573 WARN The configuration 'admin.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:24,573 INFO Kafka startTimeMs: 1626870864573 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2021-07-21 12:34:25,104 INFO [Producer clientId=producer-3] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | producer-3] 2021-07-21 12:34:25,108 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-3, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2021-07-21 12:34:25,109 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-3, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Subscribed to partition(s): dbz-caac124639bd54b45a2636390fe0c49a8-config-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2021-07-21 12:34:25,109 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-3, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Seeking to EARLIEST offset of partition dbz-caac124639bd54b45a2636390fe0c49a8-config-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,261 INFO [Consumer clientId=consumer-dbz-caac124639bd54b45a2636390fe0c49a8-3, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Resetting offset for partition dbz-caac124639bd54b45a2636390fe0c49a8-config-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker-1-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 1 rack: us-east-1b)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,262 INFO Finished reading KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-config (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,262 INFO Started KafkaBasedLog for topic dbz-caac124639bd54b45a2636390fe0c49a8-config (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,262 INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,262 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:34:26,793 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2021-07-21 12:34:27,091 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Discovered group coordinator broker-0-lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:27,093 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:27,093 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:27,595 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:30,665 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:30,763 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:34:30,764 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', leaderUrl='http://10.130.5.175:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:34:30,764 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:34:30,764 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:34:31,618 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - dbz-caac124639bd54b45a2636390fe0c49a8-config] 2021-07-21 12:35:06,911 INFO Successfully tested connection for jdbc:postgresql://debezium-pg:${port}/lb_test with user 'postgres' (io.debezium.connector.postgresql.PostgresConnector) [pool-2-thread-1] 2021-07-21 12:35:06,920 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-4-thread-1] 2021-07-21 12:35:06,923 INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig) [pool-2-thread-1] 2021-07-21 12:35:07,003 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Connector dbz-caac124639bd54b45a2636390fe0c49a8 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - dbz-caac124639bd54b45a2636390fe0c49a8-config] 2021-07-21 12:35:07,144 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,144 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,213 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully joined group with generation Generation{generationId=2, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,289 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully synced group in generation Generation{generationId=2, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,289 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', leaderUrl='http://10.130.5.175:8083/', offset=2, connectorIds=[dbz-caac124639bd54b45a2636390fe0c49a8], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,289 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connectors and tasks using config offset 2 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,291 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,298 INFO Creating connector dbz-caac124639bd54b45a2636390fe0c49a8 of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,299 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,299 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,303 INFO Instantiated connector dbz-caac124639bd54b45a2636390fe0c49a8 with version 1.5.3.Final of type class io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,303 INFO Finished creating connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2021-07-21 12:35:07,304 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,859 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:35:07,859 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,289 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Tasks [dbz-caac124639bd54b45a2636390fe0c49a8-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - dbz-caac124639bd54b45a2636390fe0c49a8-config] 2021-07-21 12:35:08,440 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Handling task config update by restarting tasks [] (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,444 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,444 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,513 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully joined group with generation Generation{generationId=3, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,585 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully synced group in generation Generation{generationId=3, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,585 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', leaderUrl='http://10.130.5.175:8083/', offset=4, connectorIds=[dbz-caac124639bd54b45a2636390fe0c49a8], taskIds=[dbz-caac124639bd54b45a2636390fe0c49a8-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,586 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connectors and tasks using config offset 4 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,597 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting task dbz-caac124639bd54b45a2636390fe0c49a8-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,598 INFO Creating task dbz-caac124639bd54b45a2636390fe0c49a8-0 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,600 INFO ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,601 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,604 INFO TaskConfig values: task.class = class io.debezium.connector.postgresql.PostgresConnectorTask (org.apache.kafka.connect.runtime.TaskConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,605 INFO Instantiated task dbz-caac124639bd54b45a2636390fe0c49a8-0 with version 1.5.3.Final of type io.debezium.connector.postgresql.PostgresConnectorTask (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,606 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,606 INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,606 INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,606 INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,607 INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,618 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,618 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,619 INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,621 INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0 compression.type = lz4 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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] 2021-07-21 12:35:08,633 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] 2021-07-21 12:35:08,633 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] 2021-07-21 12:35:08,633 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,633 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,633 INFO Kafka startTimeMs: 1626870908633 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2021-07-21 12:35:08,651 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:35:08,657 INFO Starting PostgresConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO connector.class = io.debezium.connector.postgresql.PostgresConnector (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO database.dbname = lb_test (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO database.user = postgres (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO slot.drop.on.stop = true (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO slot.name = cos_demo_msg (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO database.server.name = cos_demo (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO task.class = io.debezium.connector.postgresql.PostgresConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO database.hostname = debezium-pg (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO name = dbz-caac124639bd54b45a2636390fe0c49a8 (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO table.include.list = public.messages (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,658 INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,896 INFO user 'postgres' connected to database 'lb_test' on PostgreSQL 11.12 (Debian 11.12-1.pgdg90+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 6.3.0-18+deb9u1) 6.3.0 20170516, 64-bit with roles: role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] (io.debezium.connector.postgresql.PostgresConnectorTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,899 INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=null, catalogXmin=null] (io.debezium.connector.postgresql.connection.PostgresConnection) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,899 INFO No previous offset found (io.debezium.connector.postgresql.PostgresConnectorTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,899 INFO Taking initial snapshot for new datasource (io.debezium.connector.postgresql.snapshot.InitialSnapshotter) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,899 WARN Connector has enabled automated replication slot removal upon restart (slot.drop.on.stop = true). This setting is not recommended for production environments, as a new replication slot will be created after a connector restart, resulting in missed data change events. (io.debezium.connector.postgresql.PostgresTaskContext) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,911 INFO Creating replication slot with command CREATE_REPLICATION_SLOT cos_demo_msg LOGICAL decoderbufs (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,950 INFO Requested thread factory for connector PostgresConnector, id = cos_demo named = change-event-source-coordinator (io.debezium.util.Threads) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,952 INFO Creating thread debezium-postgresconnector-cos_demo-change-event-source-coordinator (io.debezium.util.Threads) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,953 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:35:08,958 INFO Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,961 INFO Context created (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,965 INFO Taking initial snapshot for new datasource (io.debezium.connector.postgresql.snapshot.InitialSnapshotter) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,966 INFO According to the connector configuration data will be snapshotted (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,966 INFO Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,966 INFO Setting isolation level (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,966 INFO Opening transaction with statement SET TRANSACTION ISOLATION LEVEL SERIALIZABLE, READ ONLY, DEFERRABLE; (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,994 INFO Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,998 INFO Snapshot step 3 - Locking captured tables [public.messages] (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:08,998 INFO Waiting a maximum of '10' seconds for each table lock (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,010 INFO Snapshot step 4 - Determining snapshot offset (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,011 INFO Creating initial offset context (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,013 INFO Read xlogStart at 'LSN{0/20F5588}' from transaction '710' (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,016 INFO Read xlogStart at 'LSN{0/20F5588}' from transaction '710' (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,016 INFO Snapshot step 5 - Reading structure of captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,016 INFO Reading structure of schema 'lb_test' (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,044 INFO Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,044 INFO Snapshot step 7 - Snapshotting data (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,044 INFO Snapshotting contents of 1 tables while still in transaction (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,044 INFO Exporting data from table 'public.messages' (1 of 1 tables) (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,045 INFO For table 'public.messages' using select statement: 'SELECT * FROM "public"."messages"' (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,065 INFO Finished exporting 4 records for table 'public.messages'; total duration '00:00:00.019' (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,068 INFO Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,068 INFO Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='cos_demo'db='lb_test', lsn=LSN{0/20F5588}, txId=710, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@79e1ba56, timestamp=2021-07-21T12:35:09.062Z, snapshot=FALSE, schema=public, table=messages], partition={server=cos_demo}, lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0]]] (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,071 INFO Connected metrics set to 'true' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,071 INFO Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,071 INFO Retrieved latest position from stored offset 'LSN{0/20F5588}' (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,071 INFO Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{0/20F5588}' (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,087 INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/20F5588}, catalogXmin=710] (io.debezium.connector.postgresql.connection.PostgresConnection) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,089 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-5-thread-1] 2021-07-21 12:35:09,131 INFO REPLICA IDENTITY for 'public.messages' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,134 INFO Searching for WAL resume position (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:35:09,170 INFO [Producer clientId=connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:36:08,645 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:37:09,927 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:38:09,927 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:39:09,928 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:40:09,928 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:40:44,049 INFO First LSN 'LSN{0/20F56C8}' received (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:40:44,049 INFO WAL resume position 'LSN{0/20F56C8}' discovered (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:40:44,050 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-7-thread-1] 2021-07-21 12:40:44,081 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:40:44,082 INFO Message with LSN 'LSN{0/20F56C8}' arrived, switching off the filtering (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:40:44,437 INFO 5 records sent during previous 00:05:35.83, last recorded offset: {transaction_id=null, lsn_proc=34559792, lsn=34559792, txId=711, ts_usec=1626871243714372} (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:09,929 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [SourceTaskOffsetCommitter-1] 2021-07-21 12:41:16,976 INFO Successfully tested connection for jdbc:postgresql://debezium-pg:${port}/lb_test with user 'postgres' (io.debezium.connector.postgresql.PostgresConnector) [pool-2-thread-2] 2021-07-21 12:41:16,981 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-9-thread-1] 2021-07-21 12:41:16,981 INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig) [pool-2-thread-2] 2021-07-21 12:41:17,055 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Connector dbz-caac124639bd54b45a2636390fe0c49a8 config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - dbz-caac124639bd54b45a2636390fe0c49a8-config] 2021-07-21 12:41:18,317 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Handling connector-only config update by restarting connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,317 INFO Stopping connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,318 INFO Scheduled shutdown for WorkerConnector{id=dbz-caac124639bd54b45a2636390fe0c49a8} (org.apache.kafka.connect.runtime.WorkerConnector) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,322 INFO Completed shutdown for WorkerConnector{id=dbz-caac124639bd54b45a2636390fe0c49a8} (org.apache.kafka.connect.runtime.WorkerConnector) [connector-thread-dbz-caac124639bd54b45a2636390fe0c49a8] 2021-07-21 12:41:18,343 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,343 INFO Creating connector dbz-caac124639bd54b45a2636390fe0c49a8 of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,344 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,345 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,345 INFO Instantiated connector dbz-caac124639bd54b45a2636390fe0c49a8 with version 1.5.3.Final of type class io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,345 INFO Finished creating connector dbz-caac124639bd54b45a2636390fe0c49a8 (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,353 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,353 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,786 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Tasks [dbz-caac124639bd54b45a2636390fe0c49a8-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - dbz-caac124639bd54b45a2636390fe0c49a8-config] 2021-07-21 12:41:18,925 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Handling task config update by restarting tasks [dbz-caac124639bd54b45a2636390fe0c49a8-0] (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,925 INFO Stopping task dbz-caac124639bd54b45a2636390fe0c49a8-0 (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2021-07-21 12:41:18,937 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:18,937 INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,316 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-10-thread-1] 2021-07-21 12:41:19,332 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-11-thread-1] 2021-07-21 12:41:19,332 INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:19,332 INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:19,338 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-12-thread-1] 2021-07-21 12:41:19,338 INFO [Producer clientId=connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,345 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,345 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,345 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,346 INFO App info kafka.producer for connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,354 WARN [Producer clientId=producer-2] Received invalid metadata error in produce request on partition dbz-caac124639bd54b45a2636390fe0c49a8-status-4 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender) [kafka-producer-network-thread | producer-2] 2021-07-21 12:41:19,359 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,359 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,428 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully joined group with generation Generation{generationId=4, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,498 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Successfully synced group in generation Generation{generationId=4, memberId='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,499 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Joined group at generation 4 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-4b3a00cc-d44a-487e-b3e4-a2f756477ce0', leaderUrl='http://10.130.5.175:8083/', offset=7, connectorIds=[dbz-caac124639bd54b45a2636390fe0c49a8], taskIds=[dbz-caac124639bd54b45a2636390fe0c49a8-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,499 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting connectors and tasks using config offset 7 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,500 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Starting task dbz-caac124639bd54b45a2636390fe0c49a8-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,501 INFO Creating task dbz-caac124639bd54b45a2636390fe0c49a8-0 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,501 INFO ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,502 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,502 INFO TaskConfig values: task.class = class io.debezium.connector.postgresql.PostgresConnectorTask (org.apache.kafka.connect.runtime.TaskConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO Instantiated task dbz-caac124639bd54b45a2636390fe0c49a8-0 with version 1.5.3.Final of type io.debezium.connector.postgresql.PostgresConnectorTask (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,503 INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task dbz-caac124639bd54b45a2636390fe0c49a8-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,504 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,505 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.postgresql.PostgresConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.json.JsonConverter name = dbz-caac124639bd54b45a2636390fe0c49a8 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,505 INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,505 INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [lb-cos--vcl-sghiv-ghims-t-dkuvqtvp.bf2.kafka.rhcloud.com:443] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0 compression.type = lz4 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 = 20000 retries = 2147483647 retry.backoff.ms = 500 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.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 = PLAIN security.protocol = SASL_SSL 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-3] 2021-07-21 12:41:19,545 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-3] 2021-07-21 12:41:19,545 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-3] 2021-07-21 12:41:19,545 INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,545 INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,545 INFO Kafka startTimeMs: 1626871279545 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-3] 2021-07-21 12:41:19,554 INFO [Worker clientId=connect-1, groupId=dbz-caac124639bd54b45a2636390fe0c49a8] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2021-07-21 12:41:19,568 INFO Starting PostgresConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO connector.class = io.debezium.connector.postgresql.PostgresConnector (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO database.dbname = lb_test (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO database.user = postgres (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO slot.drop.on.stop = true (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO slot.name = cos_demo_msg (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO database.server.name = cos_demo (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO task.class = io.debezium.connector.postgresql.PostgresConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO database.hostname = debezium-pg (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO name = dbz-caac124639bd54b45a2636390fe0c49a8 (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO table.include.list = public.xxx (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:19,568 INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,067 INFO [Producer clientId=connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0] Cluster ID: UjzUsZ0wSMeR1_FxgVi4hQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connector-producer-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,307 INFO Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='cos_demo'db='lb_test', lsn=LSN{0/20F5730}, txId=711, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@a5f0238, timestamp=2021-07-21T12:40:43.714372Z, snapshot=FALSE], partition={server=cos_demo}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/20F5730}, lastCommitLsn=LSN{0/20F5730}, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0]] (io.debezium.connector.common.BaseSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,309 INFO user 'postgres' connected to database 'lb_test' on PostgreSQL 11.12 (Debian 11.12-1.pgdg90+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 6.3.0-18+deb9u1) 6.3.0 20170516, 64-bit with roles: role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] (io.debezium.connector.postgresql.PostgresConnectorTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,311 INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=null, catalogXmin=null] (io.debezium.connector.postgresql.connection.PostgresConnection) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,311 INFO Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='cos_demo'db='lb_test', lsn=LSN{0/20F5730}, txId=711, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@a5f0238, timestamp=2021-07-21T12:40:43.714372Z, snapshot=FALSE], partition={server=cos_demo}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/20F5730}, lastCommitLsn=LSN{0/20F5730}, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0]] (io.debezium.connector.postgresql.PostgresConnectorTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,312 INFO Previous snapshot has completed successfully, streaming logical changes from last known position (io.debezium.connector.postgresql.snapshot.InitialSnapshotter) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,312 WARN Connector has enabled automated replication slot removal upon restart (slot.drop.on.stop = true). This setting is not recommended for production environments, as a new replication slot will be created after a connector restart, resulting in missed data change events. (io.debezium.connector.postgresql.PostgresTaskContext) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,321 INFO Creating replication slot with command CREATE_REPLICATION_SLOT cos_demo_msg LOGICAL decoderbufs (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,334 INFO Requested thread factory for connector PostgresConnector, id = cos_demo named = change-event-source-coordinator (io.debezium.util.Threads) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,335 INFO Creating thread debezium-postgresconnector-cos_demo-change-event-source-coordinator (io.debezium.util.Threads) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,335 INFO WorkerSourceTask{id=dbz-caac124639bd54b45a2636390fe0c49a8-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask) [task-thread-dbz-caac124639bd54b45a2636390fe0c49a8-0] 2021-07-21 12:41:20,335 INFO Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,339 INFO Context created (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,339 INFO Previous snapshot has completed successfully, streaming logical changes from last known position (io.debezium.connector.postgresql.snapshot.InitialSnapshotter) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,339 INFO According to the connector configuration no snapshot will be executed (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,340 INFO Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='cos_demo'db='lb_test', lsn=LSN{0/20F5730}, txId=711, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@a5f0238, timestamp=2021-07-21T12:40:43.714372Z, snapshot=FALSE], partition={server=cos_demo}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{0/20F5730}, lastCommitLsn=LSN{0/20F5730}, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0]]] (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,340 INFO Connected metrics set to 'true' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,340 INFO Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,340 INFO Retrieved latest position from stored offset 'LSN{0/20F5730}' (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,340 INFO Looking for WAL restart position for last commit LSN 'LSN{0/20F5730}' and last change LSN 'LSN{0/20F5730}' (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,352 INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/20F5A58}, catalogXmin=712] (io.debezium.connector.postgresql.connection.PostgresConnection) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:20,353 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-13-thread-1] 2021-07-21 12:41:20,393 INFO Searching for WAL resume position (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,514 INFO First LSN 'LSN{0/20F5A58}' received (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,515 INFO Received COMMIT LSN 'LSN{0/20F5B10}' larger than than last stored commit LSN 'LSN{0/20F5730}' (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,515 INFO Will restart from LSN 'LSN{0/20F5A58}' that is start of the first unprocessed transaction (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,515 INFO WAL resume position 'LSN{0/20F5A58}' discovered (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,516 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-15-thread-1] 2021-07-21 12:41:30,533 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [debezium-postgresconnector-cos_demo-change-event-source-coordinator] 2021-07-21 12:41:30,533 INFO Message with LSN 'LSN{0/20F5A58}' arrived, switching off the filtering (io.debezium.connector.postgresql.connection.WalPositionLocator) [debezium-postgresconnector-cos_demo-change-event-source-coordinator]