Kafka heap options are: -Xms512m -Xmx1g
[0] waiting for worker to boot up
I> No access restrictor found, access to any MBean is allowed
Jolokia: Agent started with URL http://127.0.0.1:8778/jolokia/
[2021-05-25 15:14:36,356] INFO WorkerInfo values:
	jvm.args = -Xms512m, -Xmx1g, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -javaagent:/usr/share/debezium_connect/lib/jolokia-jvm-agent.jar, -Dcom.sun.management.jmxremote=true, -Dcom.sun.management.jmxremote.local.only=false, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Djava.rmi.server.hostname=up-crit-debezium-iam-msk-test-2.dm.vpc, -Dcom.sun.management.jmxremote.port=9010, -Dcom.sun.management.jmxremote.rmi.port=9010, -Djolokia.port=8778, -Dcom.sun.management.jmxremote.port=9010, -Dkafka.logs.dir=/var/log/kafka, -Dlog4j.configuration=file:/etc/kafka/connect-log4j.properties
	jvm.spec = Azul Systems, Inc., OpenJDK 64-Bit Server VM, 1.8.0_212, 25.212-b04
	jvm.classpath = /usr/share/java/kafka/jetty-io-9.4.18.v20190429.jar:/usr/share/java/kafka/jackson-mapper-asl-1.9.13.jar:/usr/share/java/kafka/support-metrics-client-5.3.1-ccs.jar:/usr/share/java/kafka/kafka-streams-examples-5.3.1-ccs.jar:/usr/share/java/kafka/jackson-jaxrs-base-2.9.9.jar:/usr/share/java/kafka/osgi-resource-locator-1.0.1.jar:/usr/share/java/kafka/maven-artifact-3.6.1.jar:/usr/share/java/kafka/jetty-util-9.4.18.v20190429.jar:/usr/share/java/kafka/jackson-core-asl-1.9.13.jar:/usr/share/java/kafka/connect-json-5.3.1-ccs.jar:/usr/share/java/kafka/audience-annotations-0.5.0.jar:/usr/share/java/kafka/kafka-log4j-appender-5.3.1-ccs.jar:/usr/share/java/kafka/httpclient-4.5.7.jar:/usr/share/java/kafka/slf4j-api-1.7.26.jar:/usr/share/java/kafka/kafka.jar:/usr/share/java/kafka/jackson-annotations-2.9.9.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs-sources.jar:/usr/share/java/kafka/lz4-java-1.6.0.jar:/usr/share/java/kafka/jersey-common-2.28.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs-test.jar:/usr/share/java/kafka/commons-logging-1.2.jar:/usr/share/java/kafka/hk2-locator-2.5.0.jar:/usr/share/java/kafka/javassist-3.22.0-CR2.jar:/usr/share/java/kafka/kafka-tools-5.3.1-ccs.jar:/usr/share/java/kafka/connect-file-5.3.1-ccs.jar:/usr/share/java/kafka/slf4j-log4j12-1.7.26.jar:/usr/share/java/kafka/scala-reflect-2.12.8.jar:/usr/share/java/kafka/httpmime-4.5.7.jar:/usr/share/java/kafka/argparse4j-0.7.0.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs-javadoc.jar:/usr/share/java/kafka/jackson-module-paranamer-2.9.9.jar:/usr/share/java/kafka/jetty-server-9.4.18.v20190429.jar:/usr/share/java/kafka/jersey-media-jaxb-2.28.jar:/usr/share/java/kafka/zkclient-0.11.jar:/usr/share/java/kafka/jackson-core-2.9.9.jar:/usr/share/java/kafka/jopt-simple-5.0.4.jar:/usr/share/java/kafka/commons-lang3-3.8.1.jar:/usr/share/java/kafka/httpcore-4.4.11.jar:/usr/share/java/kafka/connect-transforms-5.3.1-ccs.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs.jar:/usr/share/java/kafka/kafka-streams-scala_2.12-5.3.1-ccs.jar:/usr/share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/usr/share/java/kafka/validation-api-2.0.1.Final.jar:/usr/share/java/kafka/jersey-server-2.28.jar:/usr/share/java/kafka/snappy-java-1.1.7.3.jar:/usr/share/java/kafka/jackson-module-jaxb-annotations-2.9.9.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs-scaladoc.jar:/usr/share/java/kafka/avro-1.8.1.jar:/usr/share/java/kafka/zookeeper-3.4.14.jar:/usr/share/java/kafka/connect-api-5.3.1-ccs.jar:/usr/share/java/kafka/jackson-datatype-jdk8-2.9.9.jar:/usr/share/java/kafka/kafka-clients-5.3.1-ccs.jar:/usr/share/java/kafka/paranamer-2.8.jar:/usr/share/java/kafka/kafka-streams-5.3.1-ccs.jar:/usr/share/java/kafka/xz-1.5.jar:/usr/share/java/kafka/jersey-client-2.28.jar:/usr/share/java/kafka/activation-1.1.1.jar:/usr/share/java/kafka/plexus-utils-3.2.0.jar:/usr/share/java/kafka/kafka_2.12-5.3.1-ccs-test-sources.jar:/usr/share/java/kafka/connect-basic-auth-extension-5.3.1-ccs.jar:/usr/share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/share/java/kafka/hk2-utils-2.5.0.jar:/usr/share/java/kafka/jackson-module-scala_2.12-2.9.9.jar:/usr/share/java/kafka/hk2-api-2.5.0.jar:/usr/share/java/kafka/jetty-servlets-9.4.18.v20190429.jar:/usr/share/java/kafka/jetty-servlet-9.4.18.v20190429.jar:/usr/share/java/kafka/guava-20.0.jar:/usr/share/java/kafka/jsr305-3.0.2.jar:/usr/share/java/kafka/jackson-dataformat-csv-2.9.9.jar:/usr/share/java/kafka/jakarta.annotation-api-1.3.4.jar:/usr/share/java/kafka/jackson-jaxrs-json-provider-2.9.9.jar:/usr/share/java/kafka/jetty-client-9.4.18.v20190429.jar:/usr/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/share/java/kafka/connect-runtime-5.3.1-ccs.jar:/usr/share/java/kafka/scala-library-2.12.8.jar:/usr/share/java/kafka/commons-compress-1.8.1.jar:/usr/share/java/kafka/jetty-security-9.4.18.v20190429.jar:/usr/share/java/kafka/scala-logging_2.12-3.9.0.jar:/usr/share/java/kafka/spotbugs-annotations-3.1.9.jar:/usr/share/java/kafka/jakarta.inject-2.5.0.jar:/usr/share/java/kafka/jetty-http-9.4.18.v20190429.jar:/usr/share/java/kafka/jersey-container-servlet-2.28.jar:/usr/share/java/kafka/jackson-databind-2.9.9.3.jar:/usr/share/java/kafka/reflections-0.9.11.jar:/usr/share/java/kafka/jaxb-api-2.3.0.jar:/usr/share/java/kafka/metrics-core-2.2.0.jar:/usr/share/java/kafka/log4j-1.2.17.jar:/usr/share/java/kafka/support-metrics-common-5.3.1-ccs.jar:/usr/share/java/kafka/commons-codec-1.11.jar:/usr/share/java/kafka/aopalliance-repackaged-2.5.0.jar:/usr/share/java/kafka/jersey-hk2-2.28.jar:/usr/share/java/kafka/kafka-streams-test-utils-5.3.1-ccs.jar:/usr/share/java/kafka/paranamer-2.7.jar:/usr/share/java/kafka/jersey-container-servlet-core-2.28.jar:/usr/share/java/kafka/rocksdbjni-5.18.3.jar:/usr/share/java/kafka/jetty-continuation-9.4.18.v20190429.jar:/usr/share/java/kafka/zstd-jni-1.4.0-1.jar:/usr/share/java/kafka/aws-msk-iam-auth-1.0.0-all.jar:/usr/share/java/kafka/confluent-metrics-5.3.1-ce.jar:/usr/share/java/confluent-common/audience-annotations-0.5.0.jar:/usr/share/java/confluent-common/slf4j-api-1.7.26.jar:/usr/share/java/confluent-common/jline-0.9.94.jar:/usr/share/java/confluent-common/common-metrics-5.3.1.jar:/usr/share/java/confluent-common/spotbugs-annotations-3.1.8.jar:/usr/share/java/confluent-common/common-utils-5.3.1.jar:/usr/share/java/confluent-common/zookeeper-3.4.14.jar:/usr/share/java/confluent-common/common-config-5.3.1.jar:/usr/share/java/confluent-common/jsr305-3.0.2.jar:/usr/share/java/confluent-common/build-tools-5.3.1.jar:/usr/share/java/confluent-common/zkclient-0.10.jar:/usr/share/java/confluent-common/netty-3.10.6.Final.jar:/usr/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.3.1.jar:/usr/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/usr/share/java/kafka-serde-tools/kafka-schema-registry-client-5.3.1.jar:/usr/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/usr/share/java/kafka-serde-tools/jackson-annotations-2.9.9.jar:/usr/share/java/kafka-serde-tools/jackson-core-2.9.9.jar:/usr/share/java/kafka-serde-tools/avro-1.8.1.jar:/usr/share/java/kafka-serde-tools/kafka-avro-serializer-5.3.1.jar:/usr/share/java/kafka-serde-tools/xz-1.5.jar:/usr/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/usr/share/java/kafka-serde-tools/kafka-json-serializer-5.3.1.jar:/usr/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/usr/share/java/kafka-serde-tools/jackson-databind-2.9.9.3.jar:/usr/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.3.1.jar:/usr/share/java/kafka-serde-tools/paranamer-2.7.jar:/usr/share/java/monitoring-interceptors/monitoring-interceptors-5.3.1.jar:/usr/bin/../share/java/kafka/jetty-io-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/jackson-mapper-asl-1.9.13.jar:/usr/bin/../share/java/kafka/support-metrics-client-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/kafka-streams-examples-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-base-2.9.9.jar:/usr/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/usr/bin/../share/java/kafka/maven-artifact-3.6.1.jar:/usr/bin/../share/java/kafka/jetty-util-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/jackson-core-asl-1.9.13.jar:/usr/bin/../share/java/kafka/connect-json-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/audience-annotations-0.5.0.jar:/usr/bin/../share/java/kafka/kafka-log4j-appender-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/httpclient-4.5.7.jar:/usr/bin/../share/java/kafka/slf4j-api-1.7.26.jar:/usr/bin/../share/java/kafka/kafka.jar:/usr/bin/../share/java/kafka/jackson-annotations-2.9.9.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs-sources.jar:/usr/bin/../share/java/kafka/lz4-java-1.6.0.jar:/usr/bin/../share/java/kafka/jersey-common-2.28.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs-test.jar:/usr/bin/../share/java/kafka/commons-logging-1.2.jar:/usr/bin/../share/java/kafka/hk2-locator-2.5.0.jar:/usr/bin/../share/java/kafka/javassist-3.22.0-CR2.jar:/usr/bin/../share/java/kafka/kafka-tools-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/connect-file-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/slf4j-log4j12-1.7.26.jar:/usr/bin/../share/java/kafka/scala-reflect-2.12.8.jar:/usr/bin/../share/java/kafka/httpmime-4.5.7.jar:/usr/bin/../share/java/kafka/argparse4j-0.7.0.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs-javadoc.jar:/usr/bin/../share/java/kafka/jackson-module-paranamer-2.9.9.jar:/usr/bin/../share/java/kafka/jetty-server-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/jersey-media-jaxb-2.28.jar:/usr/bin/../share/java/kafka/zkclient-0.11.jar:/usr/bin/../share/java/kafka/jackson-core-2.9.9.jar:/usr/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/usr/bin/../share/java/kafka/commons-lang3-3.8.1.jar:/usr/bin/../share/java/kafka/httpcore-4.4.11.jar:/usr/bin/../share/java/kafka/connect-transforms-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/kafka-streams-scala_2.12-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/usr/bin/../share/java/kafka/validation-api-2.0.1.Final.jar:/usr/bin/../share/java/kafka/jersey-server-2.28.jar:/usr/bin/../share/java/kafka/snappy-java-1.1.7.3.jar:/usr/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.9.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs-scaladoc.jar:/usr/bin/../share/java/kafka/avro-1.8.1.jar:/usr/bin/../share/java/kafka/zookeeper-3.4.14.jar:/usr/bin/../share/java/kafka/connect-api-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/jackson-datatype-jdk8-2.9.9.jar:/usr/bin/../share/java/kafka/kafka-clients-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/paranamer-2.8.jar:/usr/bin/../share/java/kafka/kafka-streams-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/xz-1.5.jar:/usr/bin/../share/java/kafka/jersey-client-2.28.jar:/usr/bin/../share/java/kafka/activation-1.1.1.jar:/usr/bin/../share/java/kafka/plexus-utils-3.2.0.jar:/usr/bin/../share/java/kafka/kafka_2.12-5.3.1-ccs-test-sources.jar:/usr/bin/../share/java/kafka/connect-basic-auth-extension-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/kafka/hk2-utils-2.5.0.jar:/usr/bin/../share/java/kafka/jackson-module-scala_2.12-2.9.9.jar:/usr/bin/../share/java/kafka/hk2-api-2.5.0.jar:/usr/bin/../share/java/kafka/jetty-servlets-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/jetty-servlet-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/guava-20.0.jar:/usr/bin/../share/java/kafka/jsr305-3.0.2.jar:/usr/bin/../share/java/kafka/jackson-dataformat-csv-2.9.9.jar:/usr/bin/../share/java/kafka/jakarta.annotation-api-1.3.4.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.9.jar:/usr/bin/../share/java/kafka/jetty-client-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/kafka/connect-runtime-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/scala-library-2.12.8.jar:/usr/bin/../share/java/kafka/commons-compress-1.8.1.jar:/usr/bin/../share/java/kafka/jetty-security-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/scala-logging_2.12-3.9.0.jar:/usr/bin/../share/java/kafka/spotbugs-annotations-3.1.9.jar:/usr/bin/../share/java/kafka/jakarta.inject-2.5.0.jar:/usr/bin/../share/java/kafka/jetty-http-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/jersey-container-servlet-2.28.jar:/usr/bin/../share/java/kafka/jackson-databind-2.9.9.3.jar:/usr/bin/../share/java/kafka/reflections-0.9.11.jar:/usr/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/usr/bin/../share/java/kafka/metrics-core-2.2.0.jar:/usr/bin/../share/java/kafka/log4j-1.2.17.jar:/usr/bin/../share/java/kafka/support-metrics-common-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/commons-codec-1.11.jar:/usr/bin/../share/java/kafka/aopalliance-repackaged-2.5.0.jar:/usr/bin/../share/java/kafka/jersey-hk2-2.28.jar:/usr/bin/../share/java/kafka/kafka-streams-test-utils-5.3.1-ccs.jar:/usr/bin/../share/java/kafka/paranamer-2.7.jar:/usr/bin/../share/java/kafka/jersey-container-servlet-core-2.28.jar:/usr/bin/../share/java/kafka/rocksdbjni-5.18.3.jar:/usr/bin/../share/java/kafka/jetty-continuation-9.4.18.v20190429.jar:/usr/bin/../share/java/kafka/zstd-jni-1.4.0-1.jar:/usr/bin/../share/java/kafka/aws-msk-iam-auth-1.0.0-all.jar:/usr/bin/../share/java/kafka/confluent-metrics-5.3.1-ce.jar:/usr/bin/../support-metrics-client/build/dependant-libs-2.12/*:/usr/bin/../support-metrics-client/build/libs/*:/usr/share/java/support-metrics-client/*:/usr/share/debezium_connect/lib/jolokia-jvm-agent.jar
	os.spec = Linux, amd64, 5.4.0-1048-aws
	os.vcpus = 4
 (org.apache.kafka.connect.runtime.WorkerInfo:71)
[2021-05-25 15:14:36,367] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90)
[2021-05-25 15:14:36,392] INFO Loading plugin from: /usr/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:38,798] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:38,798] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,799] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,800] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,800] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,800] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,800] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,800] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,802] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,802] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,802] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,802] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,803] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,804] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,805] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,806] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:38,808] INFO Loading plugin from: /usr/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:39,993] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:39,993] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:39,993] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:39,994] INFO Loading plugin from: /usr/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:41,369] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:41,369] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:41,370] INFO Loading plugin from: /usr/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:41,481] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:41,481] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:41,482] INFO Loading plugin from: /usr/share/java/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:41,594] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:41,595] INFO Added plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:41,595] INFO Loading plugin from: /usr/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:41,766] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:41,766] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:41,766] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:41,777] INFO Loading plugin from: /usr/share/java/kafka-connect-activemq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:42,143] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-activemq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:42,143] INFO Added plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:42,144] INFO Loading plugin from: /usr/share/java/kafka-connect-ibmmq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:42,398] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-ibmmq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:42,398] INFO Added plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:42,399] INFO Loading plugin from: /usr/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:42,841] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:42,841] INFO Loading plugin from: /usr/share/java/acl (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:44,915] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/acl/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:44,916] INFO Added plugin 'io.confluent.kafka.secretregistry.client.config.provider.SecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:44,916] INFO Added plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:44,916] INFO Loading plugin from: /usr/share/java/confluent-hub-client (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:45,053] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-hub-client/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:45,053] INFO Loading plugin from: /usr/share/java/monitoring-interceptors (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:45,340] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/monitoring-interceptors/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:45,340] INFO Loading plugin from: /usr/share/java/confluent-control-center (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:47,016] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-control-center/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:47,016] INFO Loading plugin from: /usr/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:47,069] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:47,070] INFO Loading plugin from: /usr/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:47,376] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:47,377] INFO Loading plugin from: /usr/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:47,451] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:47,451] INFO Loading plugin from: /usr/share/java/confluent-rebalancer (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:48,108] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-rebalancer/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:48,109] INFO Loading plugin from: /usr/share/confluent-hub-components/confluentinc-kafka-connect-gcs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:49,122] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/confluentinc-kafka-connect-gcs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:49,122] INFO Added plugin 'io.confluent.connect.gcs.GcsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,123] INFO Loading plugin from: /usr/share/connect/debezium (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2021-05-25 15:14:49,529] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/connect/debezium/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:49,529] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,529] INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:49,530] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2021-05-25 15:14:51,439] INFO Registered loader: sun.misc.Launcher$AppClassLoader@18b4aac2 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2021-05-25 15:14:51,440] INFO Added aliases 'ActiveMQSourceConnector' and 'ActiveMQSource' to plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,441] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,441] INFO Added aliases 'GcsSinkConnector' and 'GcsSink' to plugin 'io.confluent.connect.gcs.GcsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,441] INFO Added aliases 'IbmMQSourceConnector' and 'IbmMQSource' to plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,442] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,442] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,442] INFO Added aliases 'JmsSourceConnector' and 'JmsSource' to plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,442] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,443] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,443] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,443] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,443] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,444] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,444] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,444] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,444] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,445] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,445] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,445] INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,445] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,446] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,446] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,446] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,446] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,446] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,447] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,447] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,447] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,447] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,447] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,448] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,448] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,448] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,448] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,448] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,449] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,449] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,449] INFO Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,450] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,450] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,451] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,451] INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,452] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,453] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,453] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,453] INFO Added alias 'ConnectSecurityExtension' to plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,453] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2021-05-25 15:14:51,454] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,454] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2021-05-25 15:14:51,454] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
[2021-05-25 15:14:51,489] INFO DistributedConfig values:
	access.control.allow.methods =
	access.control.allow.origin =
	bootstrap.servers = [SERVERS]
	client.dns.lookup = default
	client.id =
	config.providers = []
	config.storage.replication.factor = 3
	config.storage.topic = criteria-test-debezium-config
	connect.protocol = compatible
	connections.max.idle.ms = 540000
	connector.client.config.override.policy = None
	group.id = criteria-test-debezium-connect
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	heartbeat.interval.ms = 3000
	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.storage.StringConverter
	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 = 50
	offset.storage.replication.factor = 3
	offset.storage.topic = criteria-test-debezium-offset
	plugin.path = [/usr/share/java, /usr/share/confluent-hub-components, /usr/share/connect]
	rebalance.timeout.ms = 60000
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 40000
	rest.advertised.host.name = HOSTNAME
	rest.advertised.listener = null
	rest.advertised.port = 8083
	rest.extension.classes = []
	rest.host.name = null
	rest.port = 8083
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	scheduled.rebalance.max.delay.ms = 300000
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	status.storage.partitions = 10
	status.storage.replication.factor = 3
	status.storage.topic = criteria-test-debezium-status
	task.shutdown.graceful.timeout.ms = 5000
	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:347)
[2021-05-25 15:14:51,490] INFO Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:332)
[2021-05-25 15:14:51,490] INFO Worker configuration property 'internal.key.converter.schemas.enable' (along with all configuration for 'internal.key.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:332)
[2021-05-25 15:14:51,490] INFO Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:332)
[2021-05-25 15:14:51,490] INFO Worker configuration property 'internal.value.converter.schemas.enable' (along with all configuration for 'internal.value.converter') is deprecated and may be removed in an upcoming release. The specified value 'false' matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:332)
[2021-05-25 15:14:51,492] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
[2021-05-25 15:14:51,497] INFO AdminClientConfig values:
	bootstrap.servers = [SERVERS]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	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 = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2021-05-25 15:14:51,565] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-05-25 15:14:51,675] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,676] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,677] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,678] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:51,679] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:51,679] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:51,679] INFO Kafka startTimeMs: 1621955691679 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:53,861] INFO Kafka cluster ID: BffROQm1SFCBCqgsev4kpw (org.apache.kafka.connect.util.ConnectUtils:59)
[2021-05-25 15:14:53,880] INFO Logging initialized @18062ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
[2021-05-25 15:14:53,924] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:124)
[2021-05-25 15:14:53,925] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:168)
[2021-05-25 15:14:53,933] INFO jetty-9.4.18.v20190429; built: 2019-04-29T20:42:08.989Z; git: e1bc35120a6617ee3df052294e433f3a25ce7097; jvm 1.8.0_212-b04 (org.eclipse.jetty.server.Server:370)
[2021-05-25 15:14:53,964] INFO Started http_8083@25d2f66{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292)
[2021-05-25 15:14:53,965] INFO Started @18146ms (org.eclipse.jetty.server.Server:410)
[2021-05-25 15:14:53,986] INFO Advertised URI: http://URI:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2021-05-25 15:14:53,986] INFO REST server listening at http://172.19.42.178:8083/, advertising URL http://up-crit-debezium-iam-msk-test-2.dm.vpc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:183)
[2021-05-25 15:14:53,987] INFO Advertised URI: http://URI:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2021-05-25 15:14:53,992] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2021-05-25 15:14:54,000] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:54,001] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:54,001] INFO Kafka startTimeMs: 1621955694000 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:54,186] INFO JsonConverterConfig values:
	converter.type = key
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2021-05-25 15:14:54,188] INFO JsonConverterConfig values:
	converter.type = value
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2021-05-25 15:14:54,228] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin:61)
[2021-05-25 15:14:54,262] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:54,262] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:54,262] INFO Kafka startTimeMs: 1621955694262 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:54,265] INFO Kafka Connect distributed worker initialization took 17898ms (org.apache.kafka.connect.cli.ConnectDistributed:128)
[2021-05-25 15:14:54,265] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
[2021-05-25 15:14:54,265] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:187)
[2021-05-25 15:14:54,266] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:238)
[2021-05-25 15:14:54,266] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:182)
[2021-05-25 15:14:54,266] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108)
[2021-05-25 15:14:54,266] INFO Starting KafkaBasedLog with topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:126)
[2021-05-25 15:14:54,267] INFO AdminClientConfig values:
	bootstrap.servers = [b-2.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com:9098, b-1.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com:9098, b-3.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com:9098]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	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 = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2021-05-25 15:14:54,282] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,282] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,283] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,283] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,283] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,283] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,283] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,284] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,284] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,284] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,284] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,285] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,285] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,285] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,285] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,286] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,286] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,286] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,286] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,287] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,287] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,287] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:54,288] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:54,288] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:54,288] INFO Kafka startTimeMs: 1621955694287 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:54,436] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
[2021-05-25 15:14:54,436] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
[2021-05-25 15:14:54,438] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
May 25, 2021 3:14:54 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.
May 25, 2021 3:14:54 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.
May 25, 2021 3:14:54 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.
May 25, 2021 3:14:55 PM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: 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-05-25 15:14:55,043] INFO Started o.e.j.s.ServletContextHandler@5922d3e9{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
[2021-05-25 15:14:55,044] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:233)
[2021-05-25 15:14:55,046] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2021-05-25 15:14:55,472] INFO ProducerConfig values:
	acks = all
	batch.size = 16384
	bootstrap.servers = [SERVERS]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id =
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 2147483647
	enable.idempotence = false
	interceptor.classes = []
	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
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	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:347)
[2021-05-25 15:14:55,498] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,499] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,499] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,499] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,499] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,499] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,500] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,501] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,502] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:55,502] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:55,502] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:55,502] INFO Kafka startTimeMs: 1621955695502 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:55,509] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVERS]
	check.crcs = true
	client.dns.lookup = default
	client.id =
	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 = criteria-test-debezium-connect
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	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:347)
[2021-05-25 15:14:55,536] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,536] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,536] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,536] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,537] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,538] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,539] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,539] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,539] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:55,539] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:55,539] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:55,539] INFO Kafka startTimeMs: 1621955695539 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:55,709] INFO [Producer clientId=producer-1] Cluster ID: BffROQm1SFCBCqgsev4kpw (org.apache.kafka.clients.Metadata:261)
[2021-05-25 15:14:55,844] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Cluster ID: BffROQm1SFCBCqgsev4kpw (org.apache.kafka.clients.Metadata:261)
[0] cluster "BffROQm1SFCBCqgsev4kpw" is up and running
[0] trying to create or update connector criteria-test-cdc-iam-msk
[2021-05-25 15:14:56,952] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Subscribed to partition(s): criteria-test-debezium-offset-0, criteria-test-debezium-offset-10, criteria-test-debezium-offset-20, criteria-test-debezium-offset-40, criteria-test-debezium-offset-30, criteria-test-debezium-offset-9, criteria-test-debezium-offset-39, criteria-test-debezium-offset-11, criteria-test-debezium-offset-31, criteria-test-debezium-offset-13, criteria-test-debezium-offset-18, criteria-test-debezium-offset-22, criteria-test-debezium-offset-32, criteria-test-debezium-offset-8, criteria-test-debezium-offset-43, criteria-test-debezium-offset-29, criteria-test-debezium-offset-34, criteria-test-debezium-offset-1, criteria-test-debezium-offset-6, criteria-test-debezium-offset-41, criteria-test-debezium-offset-27, criteria-test-debezium-offset-48, criteria-test-debezium-offset-5, criteria-test-debezium-offset-15, criteria-test-debezium-offset-35, criteria-test-debezium-offset-25, criteria-test-debezium-offset-46, criteria-test-debezium-offset-26, criteria-test-debezium-offset-36, criteria-test-debezium-offset-44, criteria-test-debezium-offset-16, criteria-test-debezium-offset-37, criteria-test-debezium-offset-17, criteria-test-debezium-offset-45, criteria-test-debezium-offset-3, criteria-test-debezium-offset-4, criteria-test-debezium-offset-24, criteria-test-debezium-offset-38, criteria-test-debezium-offset-33, criteria-test-debezium-offset-23, criteria-test-debezium-offset-28, criteria-test-debezium-offset-2, criteria-test-debezium-offset-12, criteria-test-debezium-offset-19, criteria-test-debezium-offset-14, criteria-test-debezium-offset-47, criteria-test-debezium-offset-49, criteria-test-debezium-offset-42, criteria-test-debezium-offset-7, criteria-test-debezium-offset-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1114)
[2021-05-25 15:14:56,955] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-40 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-30 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,956] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-39 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-31 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-32 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-43 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,957] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-29 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-34 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-41 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-27 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-48 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-35 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-25 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-46 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-26 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-36 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,958] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-44 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-37 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-45 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-38 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-33 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-28 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,959] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-47 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-49 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-42 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:56,960] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-offset-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:57,289] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-19 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,290] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-25 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,290] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-22 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,290] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-13 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-10 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-43 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-16 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-49 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-46 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,291] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-37 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,292] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-34 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,292] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-40 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,292] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-7 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,292] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-28 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,292] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,293] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-31 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,293] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-21 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,293] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-18 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,293] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-24 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,293] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-12 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-45 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-42 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-48 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-15 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-36 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,294] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,295] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-9 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,295] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-6 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,295] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-39 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,295] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-27 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,295] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,296] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-33 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,296] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-30 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,298] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-20 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,298] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-23 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,298] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-44 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,298] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-11 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-17 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-14 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-47 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-5 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,299] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-35 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,300] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-8 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,300] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-41 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,300] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-38 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,300] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-29 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,300] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-26 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,301] INFO [Consumer clientId=consumer-1, groupId=criteria-test-debezium-connect] Resetting offset for partition criteria-test-debezium-offset-32 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:352)
[2021-05-25 15:14:57,304] INFO Finished reading KafkaBasedLog for topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:159)
[2021-05-25 15:14:57,304] INFO Started KafkaBasedLog for topic criteria-test-debezium-offset (org.apache.kafka.connect.util.KafkaBasedLog:161)
[2021-05-25 15:14:57,304] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110)
[2021-05-25 15:14:57,306] INFO Worker started (org.apache.kafka.connect.runtime.Worker:187)
[2021-05-25 15:14:57,306] INFO Starting KafkaBasedLog with topic criteria-test-debezium-status (org.apache.kafka.connect.util.KafkaBasedLog:126)
[2021-05-25 15:14:57,306] INFO AdminClientConfig values:
	bootstrap.servers = [SERVERS]
	client.dns.lookup = default
	client.id =
	connections.max.idle.ms = 300000
	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 = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2021-05-25 15:14:57,313] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,313] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,314] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,315] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,315] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,315] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,315] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,316] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,316] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,316] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2021-05-25 15:14:57,316] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:57,316] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:57,316] INFO Kafka startTimeMs: 1621955697316 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:57,708] INFO ProducerConfig values:
	acks = all
	batch.size = 16384
	bootstrap.servers = [SERVERS]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id =
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	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
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 0
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	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:347)
[2021-05-25 15:14:57,715] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,716] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,717] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,718] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,719] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2021-05-25 15:14:57,719] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:57,719] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:57,719] INFO Kafka startTimeMs: 1621955697719 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:57,720] INFO ConsumerConfig values:
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [SERVERS]
	check.crcs = true
	client.dns.lookup = default
	client.id =
	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 = criteria-test-debezium-connect
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = class software.amazon.msk.auth.iam.IAMClientCallbackHandler
	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 = AWS_MSK_IAM
	security.protocol = SASL_SSL
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	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:347)
[2021-05-25 15:14:57,727] WARN The configuration 'producer.sasl.jaas.config' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'rest.advertised.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'status.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'producer.sasl.client.callback.handler.class' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'consumer.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'offset.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,728] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,729] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,729] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,729] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,729] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,729] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'producer.max.request.size' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'producer.sasl.mechanism' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'config.storage.partitions' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,730] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,731] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,731] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2021-05-25 15:14:57,731] INFO Kafka version: 5.3.1-ccs (org.apache.kafka.common.utils.AppInfoParser:117)
[2021-05-25 15:14:57,731] INFO Kafka commitId: 03799faf9878a999 (org.apache.kafka.common.utils.AppInfoParser:118)
[2021-05-25 15:14:57,731] INFO Kafka startTimeMs: 1621955697731 (org.apache.kafka.common.utils.AppInfoParser:119)
[2021-05-25 15:14:57,833] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Cluster ID: BffROQm1SFCBCqgsev4kpw (org.apache.kafka.clients.Metadata:261)
[2021-05-25 15:14:58,151] INFO [Producer clientId=producer-2] Failed authentication with b-3.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com/172.19.50.228 ([d8a98593-cffb-4500-b9ec-1511d8ba7fb3]: Too many connects) (org.apache.kafka.common.network.Selector:617)
[2021-05-25 15:14:58,153] ERROR [Producer clientId=producer-2] Connection to node -3 (b-3.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com/172.19.50.228:9098) failed authentication due to: [d8a98593-cffb-4500-b9ec-1511d8ba7fb3]: Too many connects (org.apache.kafka.clients.NetworkClient:737)
[2021-05-25 15:14:58,361] INFO [Producer clientId=producer-2] Cluster ID: BffROQm1SFCBCqgsev4kpw (org.apache.kafka.clients.Metadata:261)
[2021-05-25 15:14:58,563] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Subscribed to partition(s): criteria-test-debezium-status-0, criteria-test-debezium-status-5, criteria-test-debezium-status-2, criteria-test-debezium-status-8, criteria-test-debezium-status-9, criteria-test-debezium-status-4, criteria-test-debezium-status-1, criteria-test-debezium-status-6, criteria-test-debezium-status-7, criteria-test-debezium-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1114)
[2021-05-25 15:14:58,563] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,563] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,563] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,563] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,564] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Seeking to EARLIEST offset of partition criteria-test-debezium-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:523)
[2021-05-25 15:14:58,898] INFO [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Failed authentication with b-2.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com/172.19.34.95 ([995eb066-1f56-4680-b587-8a078acb1ede]: Too many connects) (org.apache.kafka.common.network.Selector:617)
[2021-05-25 15:14:58,899] ERROR [Consumer clientId=consumer-2, groupId=criteria-test-debezium-connect] Connection to node 2 (b-2.eval-iam-auth-test.hdg747.c4.kafka.us-east-1.amazonaws.com/172.19.34.95:9098) failed authentication due to: [995eb066-1f56-4680-b587-8a078acb1ede]: Too many connects (org.apache.kafka.clients.NetworkClient:737)
[2021-05-25 15:14:58,900] ERROR [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Uncaught exception in herder work thread, exiting:  (org.apache.kafka.connect.runtime.distributed.DistributedHerder:253)
org.apache.kafka.common.errors.SaslAuthenticationException: [995eb066-1f56-4680-b587-8a078acb1ede]: Too many connects
[2021-05-25 15:14:58,902] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:66)
[2021-05-25 15:14:58,903] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:241)
[0] create/update connector criteria-test-cdc-iam-msk failed with code: 100, retry in 0 seconds
[2021-05-25 15:15:58,907] INFO Stopped http_8083@25d2f66{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:341)
[2021-05-25 15:15:58,908] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
[1] trying to create or update connector criteria-test-cdc-iam-msk
[1] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 1 seconds
[2] trying to create or update connector criteria-test-cdc-iam-msk
[2] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 1 seconds
[3] trying to create or update connector criteria-test-cdc-iam-msk
[3] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 1 seconds
[4] trying to create or update connector criteria-test-cdc-iam-msk
[4] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 0 seconds
[5] trying to create or update connector criteria-test-cdc-iam-msk
[5] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 1 seconds
[6] trying to create or update connector criteria-test-cdc-iam-msk
[6] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 10 seconds
[7] trying to create or update connector criteria-test-cdc-iam-msk
[7] create/update connector criteria-test-cdc-iam-msk failed with code: 000, retry in 60 seconds
[2021-05-25 15:16:26,056] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:258)
[2021-05-25 15:16:26,060] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:533)
[2021-05-25 15:16:31,062] INFO [Worker clientId=connect-1, groupId=criteria-test-debezium-connect] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:553)
[2021-05-25 15:16:31,062] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:71)