· 6 years ago · May 15, 2019, 08:10 AM
1[2019-05-15 13:26:03,758] INFO WorkerInfo values:
2 jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/var/folders/v_/7m_lyfvj0kn60xfwj10z41kh0000gn/T/confluent.vNwj5Kr1/connect/logs, -Dlog4j.configuration=file:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../etc/kafka/connect-log4j.properties
3 jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_201, 25.201-b09
4 jvm.classpath = /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-databind-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-core-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-runtime-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-logging-1.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2-javadoc.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-log4j-appender-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-continuation-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/reflections-0.9.11.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2-scaladoc.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/slf4j-log4j12-1.7.25.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/zstd-jni-1.3.8-1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/xz-1.5.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2-sources.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jopt-simple-5.0.4.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-api-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-transforms-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/hk2-api-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/plexus-utils-3.1.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/guava-20.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-clients-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/argparse4j-0.7.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/activation-1.1.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jline-0.9.94.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/slf4j-api-1.7.25.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-common-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.servlet-api-3.1.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/maven-artifact-3.6.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/log4j-1.2.17.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-io-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-module-jaxb-annotations-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2-test-sources.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/validation-api-1.1.0.Final.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-streams-test-utils-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-jaxrs-json-provider-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-media-jaxb-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-streams-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-util-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-server-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/zkclient-0.11.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-tools-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka_2.12-2.2.0-cp2-test.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/zkclient-0.10.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/scala-logging_2.12-3.9.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.annotation-api-1.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/zookeeper-3.4.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-streams-examples-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/httpclient-4.5.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-codec-1.9.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-servlets-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-validator-1.5.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka-streams-scala_2.12-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javassist-3.22.0-CR2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-server-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jaxb-api-2.3.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-compress-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/lz4-java-1.5.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/metrics-core-2.2.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-container-servlet-core-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-core-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/osgi-resource-locator-1.0.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/snappy-java-1.1.7.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/support-metrics-client-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-servlet-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/paranamer-2.7.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-container-servlet-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/audience-annotations-0.5.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-basic-auth-extension-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-collections-3.2.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-annotations-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/netty-3.10.6.Final.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/aopalliance-repackaged-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/hk2-locator-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-hk2-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/scala-library-2.12.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-lang3-3.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-client-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/httpcore-4.4.4.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/scala-reflect-2.12.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-json-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-http-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.ws.rs-api-2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/avro-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.inject-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/common-utils-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-beanutils-1.9.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/httpmime-4.5.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-mapper-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-datatype-jdk8-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/kafka.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/hk2-utils-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/javax.inject-1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/support-metrics-common-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jackson-jaxrs-base-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-lang3-3.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jersey-client-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/commons-digester-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/connect-file-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/jetty-security-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/rocksdbjni-5.15.10.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/common-config-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/jline-0.9.94.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/common-metrics-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/slf4j-api-1.7.25.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/zkclient-0.10.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/zookeeper-3.4.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/audience-annotations-0.5.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/build-tools-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/netty-3.10.6.Final.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/common-utils-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/jackson-databind-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/jackson-core-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/xz-1.5.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/kafka-schema-registry-client-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/paranamer-2.7.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/jackson-annotations-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/kafka-avro-serializer-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/kafka-json-serializer-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/avro-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-databind-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-core-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-runtime-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-logging-1.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2-javadoc.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-log4j-appender-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-continuation-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/reflections-0.9.11.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2-scaladoc.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/slf4j-log4j12-1.7.25.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/zstd-jni-1.3.8-1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/xz-1.5.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2-sources.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-api-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-transforms-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/hk2-api-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/plexus-utils-3.1.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/guava-20.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-clients-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/argparse4j-0.7.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/activation-1.1.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jline-0.9.94.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/slf4j-api-1.7.25.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-common-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/maven-artifact-3.6.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/log4j-1.2.17.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-io-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2-test-sources.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/validation-api-1.1.0.Final.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-streams-test-utils-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-media-jaxb-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-streams-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-util-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-server-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/zkclient-0.11.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-tools-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka_2.12-2.2.0-cp2-test.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/zkclient-0.10.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/scala-logging_2.12-3.9.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.annotation-api-1.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/zookeeper-3.4.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-streams-examples-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/httpclient-4.5.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-codec-1.9.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-servlets-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-validator-1.5.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka-streams-scala_2.12-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javassist-3.22.0-CR2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-server-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-compress-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/lz4-java-1.5.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/metrics-core-2.2.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-container-servlet-core-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-core-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/snappy-java-1.1.7.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/support-metrics-client-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-servlet-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/paranamer-2.7.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-container-servlet-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/audience-annotations-0.5.0.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.ws.rs-api-2.1.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-basic-auth-extension-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-collections-3.2.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-annotations-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/netty-3.10.6.Final.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/aopalliance-repackaged-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/hk2-locator-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-hk2-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/scala-library-2.12.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-lang3-3.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-client-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/httpcore-4.4.4.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/scala-reflect-2.12.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-json-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-http-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.ws.rs-api-2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/avro-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.inject-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/common-utils-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-beanutils-1.9.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/httpmime-4.5.2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-mapper-asl-1.9.13.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-datatype-jdk8-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/kafka.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/hk2-utils-2.5.0-b42.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/javax.inject-1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/support-metrics-common-5.2.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jackson-jaxrs-base-2.9.8.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-lang3-3.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jersey-client-2.27.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/commons-digester-1.8.1.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/connect-file-2.2.0-cp2.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/jetty-security-9.4.14.v20181114.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/kafka/rocksdbjni-5.15.10.jar:/Users/OnGrid/Documents/kafka/confluent-platform/bin/../share/java/confluent-support-metrics/*:/usr/share/java/confluent-support-metrics/*
5 os.spec = Mac OS X, x86_64, 10.14.4
6 os.vcpus = 8
7 (org.apache.kafka.connect.runtime.WorkerInfo:71)
8[2019-05-15 13:26:03,777] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:89)
9[2019-05-15 13:26:03,810] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
10[2019-05-15 13:26:04,870] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
11[2019-05-15 13:26:04,871] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
12[2019-05-15 13:26:04,871] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
13[2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
14[2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
15[2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
16[2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
17[2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
18[2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
19[2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
20[2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
21[2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
22[2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
23[2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
24[2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
25[2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
26[2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
27[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
28[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
29[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
30[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
31[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
32[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
33[2019-05-15 13:26:04,876] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
34[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
35[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
36[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
37[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
38[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
39[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
40[2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
41[2019-05-15 13:26:04,878] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
42[2019-05-15 13:26:04,878] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
43[2019-05-15 13:26:04,878] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
44[2019-05-15 13:26:04,878] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
45[2019-05-15 13:26:04,879] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
46[2019-05-15 13:26:04,880] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-rest (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
47[2019-05-15 13:26:05,770] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-rest/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
48[2019-05-15 13:26:05,770] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
49[2019-05-15 13:26:06,171] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
50[2019-05-15 13:26:06,172] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/ksql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
51[2019-05-15 13:26:08,475] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/ksql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
52[2019-05-15 13:26:08,475] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
53[2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
54[2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
55[2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
56[2019-05-15 13:26:08,476] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
57[2019-05-15 13:26:08,897] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
58[2019-05-15 13:26:08,898] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
59[2019-05-15 13:26:09,600] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
60[2019-05-15 13:26:09,624] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
61[2019-05-15 13:26:09,624] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
62[2019-05-15 13:26:09,625] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
63[2019-05-15 13:26:09,625] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
64[2019-05-15 13:26:19,661] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
65[2019-05-15 13:26:19,669] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
66[2019-05-15 13:26:19,669] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
67[2019-05-15 13:26:19,799] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
68[2019-05-15 13:26:19,869] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
69[2019-05-15 13:26:19,869] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
70[2019-05-15 13:26:20,081] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
71[2019-05-15 13:26:20,082] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
72[2019-05-15 13:26:22,375] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
73[2019-05-15 13:26:22,376] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
74[2019-05-15 13:26:22,376] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
75[2019-05-15 13:26:22,411] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
76[2019-05-15 13:26:22,739] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
77[2019-05-15 13:26:22,739] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
78[2019-05-15 13:26:22,740] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
79[2019-05-15 13:26:22,757] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
80[2019-05-15 13:26:25,193] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
81[2019-05-15 13:26:25,321] INFO Loading plugin from: /Users/OnGrid/Documents/kafka/confluent-platform/share/confluent-hub-components/debezium-debezium-connector-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:215)
82[2019-05-15 13:26:25,988] INFO Registered loader: PluginClassLoader{pluginLocation=file:/Users/OnGrid/Documents/kafka/confluent-platform/share/confluent-hub-components/debezium-debezium-connector-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
83[2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
84[2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
85[2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
86[2019-05-15 13:26:25,989] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
87[2019-05-15 13:26:27,407] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
88[2019-05-15 13:26:27,408] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
89[2019-05-15 13:26:27,409] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
90[2019-05-15 13:26:27,409] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
91[2019-05-15 13:26:27,409] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
92[2019-05-15 13:26:27,409] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
93[2019-05-15 13:26:27,410] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
94[2019-05-15 13:26:27,410] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
95[2019-05-15 13:26:27,410] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
96[2019-05-15 13:26:27,410] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
97[2019-05-15 13:26:27,410] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
98[2019-05-15 13:26:27,410] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
99[2019-05-15 13:26:27,411] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
100[2019-05-15 13:26:27,411] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
101[2019-05-15 13:26:27,411] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
102[2019-05-15 13:26:27,411] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
103[2019-05-15 13:26:27,411] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
104[2019-05-15 13:26:27,412] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
105[2019-05-15 13:26:27,412] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
106[2019-05-15 13:26:27,412] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
107[2019-05-15 13:26:27,412] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
108[2019-05-15 13:26:27,412] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
109[2019-05-15 13:26:27,412] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
110[2019-05-15 13:26:27,412] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
111[2019-05-15 13:26:27,413] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
112[2019-05-15 13:26:27,413] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
113[2019-05-15 13:26:27,413] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
114[2019-05-15 13:26:27,413] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
115[2019-05-15 13:26:27,413] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
116[2019-05-15 13:26:27,413] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
117[2019-05-15 13:26:27,413] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
118[2019-05-15 13:26:27,414] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:386)
119[2019-05-15 13:26:27,414] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
120[2019-05-15 13:26:27,414] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
121[2019-05-15 13:26:27,414] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
122[2019-05-15 13:26:27,415] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
123[2019-05-15 13:26:27,415] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
124[2019-05-15 13:26:27,416] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
125[2019-05-15 13:26:27,416] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:383)
126[2019-05-15 13:26:27,433] INFO DistributedConfig values:
127 access.control.allow.methods =
128 access.control.allow.origin =
129 bootstrap.servers = [localhost:9092]
130 client.dns.lookup = default
131 client.id =
132 config.providers = []
133 config.storage.replication.factor = 1
134 config.storage.topic = connect-configs
135 connections.max.idle.ms = 540000
136 group.id = connect-cluster
137 header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
138 heartbeat.interval.ms = 3000
139 internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
140 internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
141 key.converter = class io.confluent.connect.avro.AvroConverter
142 listeners = null
143 metadata.max.age.ms = 300000
144 metric.reporters = []
145 metrics.num.samples = 2
146 metrics.recording.level = INFO
147 metrics.sample.window.ms = 30000
148 offset.flush.interval.ms = 60000
149 offset.flush.timeout.ms = 5000
150 offset.storage.partitions = 25
151 offset.storage.replication.factor = 1
152 offset.storage.topic = connect-offsets
153 plugin.path = [/Users/OnGrid/Documents/kafka/confluent-platform/share/java, /Users/OnGrid/Documents/kafka/confluent-platform/share/confluent-hub-components]
154 rebalance.timeout.ms = 60000
155 receive.buffer.bytes = 32768
156 reconnect.backoff.max.ms = 1000
157 reconnect.backoff.ms = 50
158 request.timeout.ms = 40000
159 rest.advertised.host.name = null
160 rest.advertised.listener = null
161 rest.advertised.port = null
162 rest.extension.classes = []
163 rest.host.name = null
164 rest.port = 8083
165 retry.backoff.ms = 100
166 sasl.client.callback.handler.class = null
167 sasl.jaas.config = null
168 sasl.kerberos.kinit.cmd = /usr/bin/kinit
169 sasl.kerberos.min.time.before.relogin = 60000
170 sasl.kerberos.service.name = null
171 sasl.kerberos.ticket.renew.jitter = 0.05
172 sasl.kerberos.ticket.renew.window.factor = 0.8
173 sasl.login.callback.handler.class = null
174 sasl.login.class = null
175 sasl.login.refresh.buffer.seconds = 300
176 sasl.login.refresh.min.period.seconds = 60
177 sasl.login.refresh.window.factor = 0.8
178 sasl.login.refresh.window.jitter = 0.05
179 sasl.mechanism = GSSAPI
180 security.protocol = PLAINTEXT
181 send.buffer.bytes = 131072
182 session.timeout.ms = 10000
183 ssl.cipher.suites = null
184 ssl.client.auth = none
185 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
186 ssl.endpoint.identification.algorithm = https
187 ssl.key.password = null
188 ssl.keymanager.algorithm = SunX509
189 ssl.keystore.location = null
190 ssl.keystore.password = null
191 ssl.keystore.type = JKS
192 ssl.protocol = TLS
193 ssl.provider = null
194 ssl.secure.random.implementation = null
195 ssl.trustmanager.algorithm = PKIX
196 ssl.truststore.location = null
197 ssl.truststore.password = null
198 ssl.truststore.type = JKS
199 status.storage.partitions = 5
200 status.storage.replication.factor = 1
201 status.storage.topic = connect-statuses
202 task.shutdown.graceful.timeout.ms = 5000
203 value.converter = class io.confluent.connect.avro.AvroConverter
204 worker.sync.timeout.ms = 3000
205 worker.unsync.backoff.ms = 300000
206 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:279)
207[2019-05-15 13:26:27,434] 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:322)
208[2019-05-15 13:26:27,434] 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:322)
209[2019-05-15 13:26:27,434] 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:322)
210[2019-05-15 13:26:27,434] 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:322)
211[2019-05-15 13:26:27,436] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
212[2019-05-15 13:26:27,444] INFO AdminClientConfig values:
213 bootstrap.servers = [localhost:9092]
214 client.dns.lookup = default
215 client.id =
216 connections.max.idle.ms = 300000
217 metadata.max.age.ms = 300000
218 metric.reporters = []
219 metrics.num.samples = 2
220 metrics.recording.level = INFO
221 metrics.sample.window.ms = 30000
222 receive.buffer.bytes = 65536
223 reconnect.backoff.max.ms = 1000
224 reconnect.backoff.ms = 50
225 request.timeout.ms = 120000
226 retries = 5
227 retry.backoff.ms = 100
228 sasl.client.callback.handler.class = null
229 sasl.jaas.config = null
230 sasl.kerberos.kinit.cmd = /usr/bin/kinit
231 sasl.kerberos.min.time.before.relogin = 60000
232 sasl.kerberos.service.name = null
233 sasl.kerberos.ticket.renew.jitter = 0.05
234 sasl.kerberos.ticket.renew.window.factor = 0.8
235 sasl.login.callback.handler.class = null
236 sasl.login.class = null
237 sasl.login.refresh.buffer.seconds = 300
238 sasl.login.refresh.min.period.seconds = 60
239 sasl.login.refresh.window.factor = 0.8
240 sasl.login.refresh.window.jitter = 0.05
241 sasl.mechanism = GSSAPI
242 security.protocol = PLAINTEXT
243 send.buffer.bytes = 131072
244 ssl.cipher.suites = null
245 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
246 ssl.endpoint.identification.algorithm = https
247 ssl.key.password = null
248 ssl.keymanager.algorithm = SunX509
249 ssl.keystore.location = null
250 ssl.keystore.password = null
251 ssl.keystore.type = JKS
252 ssl.protocol = TLS
253 ssl.provider = null
254 ssl.secure.random.implementation = null
255 ssl.trustmanager.algorithm = PKIX
256 ssl.truststore.location = null
257 ssl.truststore.password = null
258 ssl.truststore.type = JKS
259 (org.apache.kafka.clients.admin.AdminClientConfig:279)
260[2019-05-15 13:26:27,491] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
261[2019-05-15 13:26:27,491] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
262[2019-05-15 13:26:27,492] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
263[2019-05-15 13:26:27,492] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
264[2019-05-15 13:26:27,492] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
265[2019-05-15 13:26:27,492] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
266[2019-05-15 13:26:27,492] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
267[2019-05-15 13:26:27,492] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
268[2019-05-15 13:26:27,492] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
269[2019-05-15 13:26:27,492] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
270[2019-05-15 13:26:27,492] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
271[2019-05-15 13:26:27,492] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
272[2019-05-15 13:26:27,492] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
273[2019-05-15 13:26:27,493] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
274[2019-05-15 13:26:27,493] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
275[2019-05-15 13:26:27,493] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
276[2019-05-15 13:26:27,493] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
277[2019-05-15 13:26:27,493] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
278[2019-05-15 13:26:27,670] INFO Kafka cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.connect.util.ConnectUtils:59)
279[2019-05-15 13:26:27,692] INFO Logging initialized @29502ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
280[2019-05-15 13:26:27,740] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:120)
281[2019-05-15 13:26:27,741] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:164)
282[2019-05-15 13:26:27,830] INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git: c4550056e785fb5665914545889f21dc136ad9e6; jvm 1.8.0_201-b09 (org.eclipse.jetty.server.Server:370)
283[2019-05-15 13:26:27,866] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
284[2019-05-15 13:26:27,866] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
285[2019-05-15 13:26:27,868] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
286May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
287WARNING: 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.
288May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
289WARNING: 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.
290May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
291WARNING: 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.
292May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.Errors logErrors
293WARNING: 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.
294WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
295WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
296WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
297
298[2019-05-15 13:26:28,520] INFO Started o.e.j.s.ServletContextHandler@65eb76cd{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
299[2019-05-15 13:26:28,557] INFO Started http_8083@33f2df51{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292)
300[2019-05-15 13:26:28,558] INFO Started @30367ms (org.eclipse.jetty.server.Server:407)
301[2019-05-15 13:26:38,567] INFO Advertised URI: http://192.168.1.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:271)
302[2019-05-15 13:26:38,572] INFO REST server listening at http://192.168.1.5:8083/, advertising URL http://192.168.1.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:219)
303[2019-05-15 13:26:43,576] INFO Advertised URI: http://192.168.1.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:271)
304[2019-05-15 13:26:43,589] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
305[2019-05-15 13:26:43,589] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
306[2019-05-15 13:26:43,723] INFO JsonConverterConfig values:
307 converter.type = key
308 schemas.cache.size = 1000
309 schemas.enable = false
310 (org.apache.kafka.connect.json.JsonConverterConfig:279)
311[2019-05-15 13:26:43,725] INFO JsonConverterConfig values:
312 converter.type = value
313 schemas.cache.size = 1000
314 schemas.enable = false
315 (org.apache.kafka.connect.json.JsonConverterConfig:279)
316[2019-05-15 13:26:43,765] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
317[2019-05-15 13:26:43,765] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
318[2019-05-15 13:26:43,768] INFO Kafka Connect distributed worker initialization took 39992ms (org.apache.kafka.connect.cli.ConnectDistributed:124)
319[2019-05-15 13:26:43,768] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
320[2019-05-15 13:26:43,768] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)
321[2019-05-15 13:26:43,768] INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:212)
322[2019-05-15 13:26:43,769] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:162)
323[2019-05-15 13:26:43,769] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108)
324[2019-05-15 13:26:43,769] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:125)
325[2019-05-15 13:26:43,769] INFO AdminClientConfig values:
326 bootstrap.servers = [localhost:9092]
327 client.dns.lookup = default
328 client.id =
329 connections.max.idle.ms = 300000
330 metadata.max.age.ms = 300000
331 metric.reporters = []
332 metrics.num.samples = 2
333 metrics.recording.level = INFO
334 metrics.sample.window.ms = 30000
335 receive.buffer.bytes = 65536
336 reconnect.backoff.max.ms = 1000
337 reconnect.backoff.ms = 50
338 request.timeout.ms = 120000
339 retries = 5
340 retry.backoff.ms = 100
341 sasl.client.callback.handler.class = null
342 sasl.jaas.config = null
343 sasl.kerberos.kinit.cmd = /usr/bin/kinit
344 sasl.kerberos.min.time.before.relogin = 60000
345 sasl.kerberos.service.name = null
346 sasl.kerberos.ticket.renew.jitter = 0.05
347 sasl.kerberos.ticket.renew.window.factor = 0.8
348 sasl.login.callback.handler.class = null
349 sasl.login.class = null
350 sasl.login.refresh.buffer.seconds = 300
351 sasl.login.refresh.min.period.seconds = 60
352 sasl.login.refresh.window.factor = 0.8
353 sasl.login.refresh.window.jitter = 0.05
354 sasl.mechanism = GSSAPI
355 security.protocol = PLAINTEXT
356 send.buffer.bytes = 131072
357 ssl.cipher.suites = null
358 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
359 ssl.endpoint.identification.algorithm = https
360 ssl.key.password = null
361 ssl.keymanager.algorithm = SunX509
362 ssl.keystore.location = null
363 ssl.keystore.password = null
364 ssl.keystore.type = JKS
365 ssl.protocol = TLS
366 ssl.provider = null
367 ssl.secure.random.implementation = null
368 ssl.trustmanager.algorithm = PKIX
369 ssl.truststore.location = null
370 ssl.truststore.password = null
371 ssl.truststore.type = JKS
372 (org.apache.kafka.clients.admin.AdminClientConfig:279)
373[2019-05-15 13:26:43,773] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
374[2019-05-15 13:26:43,773] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
375[2019-05-15 13:26:43,773] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
376[2019-05-15 13:26:43,773] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
377[2019-05-15 13:26:43,773] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
378[2019-05-15 13:26:43,773] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
379[2019-05-15 13:26:43,773] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
380[2019-05-15 13:26:43,773] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
381[2019-05-15 13:26:43,773] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
382[2019-05-15 13:26:43,773] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
383[2019-05-15 13:26:43,774] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
384[2019-05-15 13:26:43,774] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
385[2019-05-15 13:26:43,774] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
386[2019-05-15 13:26:43,774] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
387[2019-05-15 13:26:43,774] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
388[2019-05-15 13:26:43,774] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
389[2019-05-15 13:26:43,774] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
390[2019-05-15 13:26:43,774] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
391[2019-05-15 13:26:44,261] INFO Created topic (name=connect-offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:229)
392[2019-05-15 13:26:44,287] INFO ProducerConfig values:
393 acks = all
394 batch.size = 16384
395 bootstrap.servers = [localhost:9092]
396 buffer.memory = 33554432
397 client.dns.lookup = default
398 client.id =
399 compression.type = none
400 connections.max.idle.ms = 540000
401 delivery.timeout.ms = 2147483647
402 enable.idempotence = false
403 interceptor.classes = []
404 key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
405 linger.ms = 0
406 max.block.ms = 60000
407 max.in.flight.requests.per.connection = 1
408 max.request.size = 1048576
409 metadata.max.age.ms = 300000
410 metric.reporters = []
411 metrics.num.samples = 2
412 metrics.recording.level = INFO
413 metrics.sample.window.ms = 30000
414 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
415 receive.buffer.bytes = 32768
416 reconnect.backoff.max.ms = 1000
417 reconnect.backoff.ms = 50
418 request.timeout.ms = 30000
419 retries = 2147483647
420 retry.backoff.ms = 100
421 sasl.client.callback.handler.class = null
422 sasl.jaas.config = null
423 sasl.kerberos.kinit.cmd = /usr/bin/kinit
424 sasl.kerberos.min.time.before.relogin = 60000
425 sasl.kerberos.service.name = null
426 sasl.kerberos.ticket.renew.jitter = 0.05
427 sasl.kerberos.ticket.renew.window.factor = 0.8
428 sasl.login.callback.handler.class = null
429 sasl.login.class = null
430 sasl.login.refresh.buffer.seconds = 300
431 sasl.login.refresh.min.period.seconds = 60
432 sasl.login.refresh.window.factor = 0.8
433 sasl.login.refresh.window.jitter = 0.05
434 sasl.mechanism = GSSAPI
435 security.protocol = PLAINTEXT
436 send.buffer.bytes = 131072
437 ssl.cipher.suites = null
438 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
439 ssl.endpoint.identification.algorithm = https
440 ssl.key.password = null
441 ssl.keymanager.algorithm = SunX509
442 ssl.keystore.location = null
443 ssl.keystore.password = null
444 ssl.keystore.type = JKS
445 ssl.protocol = TLS
446 ssl.provider = null
447 ssl.secure.random.implementation = null
448 ssl.trustmanager.algorithm = PKIX
449 ssl.truststore.location = null
450 ssl.truststore.password = null
451 ssl.truststore.type = JKS
452 transaction.timeout.ms = 60000
453 transactional.id = null
454 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
455 (org.apache.kafka.clients.producer.ProducerConfig:279)
456[2019-05-15 13:26:44,312] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
457[2019-05-15 13:26:44,312] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
458[2019-05-15 13:26:44,313] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
459[2019-05-15 13:26:44,313] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
460[2019-05-15 13:26:44,313] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
461[2019-05-15 13:26:44,313] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
462[2019-05-15 13:26:44,313] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
463[2019-05-15 13:26:44,313] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
464[2019-05-15 13:26:44,313] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
465[2019-05-15 13:26:44,314] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
466[2019-05-15 13:26:44,314] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
467[2019-05-15 13:26:44,314] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
468[2019-05-15 13:26:44,314] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
469[2019-05-15 13:26:44,314] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
470[2019-05-15 13:26:44,314] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
471[2019-05-15 13:26:44,314] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
472[2019-05-15 13:26:44,315] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
473[2019-05-15 13:26:44,315] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
474[2019-05-15 13:26:44,326] INFO ConsumerConfig values:
475 auto.commit.interval.ms = 5000
476 auto.offset.reset = earliest
477 bootstrap.servers = [localhost:9092]
478 check.crcs = true
479 client.dns.lookup = default
480 client.id =
481 connections.max.idle.ms = 540000
482 default.api.timeout.ms = 60000
483 enable.auto.commit = false
484 exclude.internal.topics = true
485 fetch.max.bytes = 52428800
486 fetch.max.wait.ms = 500
487 fetch.min.bytes = 1
488 group.id = connect-cluster
489 heartbeat.interval.ms = 3000
490 interceptor.classes = []
491 internal.leave.group.on.close = true
492 isolation.level = read_uncommitted
493 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
494 max.partition.fetch.bytes = 1048576
495 max.poll.interval.ms = 300000
496 max.poll.records = 500
497 metadata.max.age.ms = 300000
498 metric.reporters = []
499 metrics.num.samples = 2
500 metrics.recording.level = INFO
501 metrics.sample.window.ms = 30000
502 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
503 receive.buffer.bytes = 65536
504 reconnect.backoff.max.ms = 1000
505 reconnect.backoff.ms = 50
506 request.timeout.ms = 30000
507 retry.backoff.ms = 100
508 sasl.client.callback.handler.class = null
509 sasl.jaas.config = null
510 sasl.kerberos.kinit.cmd = /usr/bin/kinit
511 sasl.kerberos.min.time.before.relogin = 60000
512 sasl.kerberos.service.name = null
513 sasl.kerberos.ticket.renew.jitter = 0.05
514 sasl.kerberos.ticket.renew.window.factor = 0.8
515 sasl.login.callback.handler.class = null
516 sasl.login.class = null
517 sasl.login.refresh.buffer.seconds = 300
518 sasl.login.refresh.min.period.seconds = 60
519 sasl.login.refresh.window.factor = 0.8
520 sasl.login.refresh.window.jitter = 0.05
521 sasl.mechanism = GSSAPI
522 security.protocol = PLAINTEXT
523 send.buffer.bytes = 131072
524 session.timeout.ms = 10000
525 ssl.cipher.suites = null
526 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
527 ssl.endpoint.identification.algorithm = https
528 ssl.key.password = null
529 ssl.keymanager.algorithm = SunX509
530 ssl.keystore.location = null
531 ssl.keystore.password = null
532 ssl.keystore.type = JKS
533 ssl.protocol = TLS
534 ssl.provider = null
535 ssl.secure.random.implementation = null
536 ssl.trustmanager.algorithm = PKIX
537 ssl.truststore.location = null
538 ssl.truststore.password = null
539 ssl.truststore.type = JKS
540 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
541 (org.apache.kafka.clients.consumer.ConsumerConfig:279)
542[2019-05-15 13:26:44,357] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
543[2019-05-15 13:26:44,357] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
544[2019-05-15 13:26:44,357] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
545[2019-05-15 13:26:44,357] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
546[2019-05-15 13:26:44,357] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
547[2019-05-15 13:26:44,357] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
548[2019-05-15 13:26:44,358] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
549[2019-05-15 13:26:44,358] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
550[2019-05-15 13:26:44,358] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
551[2019-05-15 13:26:44,358] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
552[2019-05-15 13:26:44,358] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
553[2019-05-15 13:26:44,358] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
554[2019-05-15 13:26:44,358] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
555[2019-05-15 13:26:44,358] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
556[2019-05-15 13:26:44,358] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
557[2019-05-15 13:26:44,359] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
558[2019-05-15 13:26:44,359] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
559[2019-05-15 13:26:44,396] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Subscribed to partition(s): connect-offsets-0, connect-offsets-5, connect-offsets-10, connect-offsets-20, connect-offsets-15, connect-offsets-9, connect-offsets-11, connect-offsets-4, connect-offsets-16, connect-offsets-17, connect-offsets-3, connect-offsets-24, connect-offsets-23, connect-offsets-13, connect-offsets-18, connect-offsets-22, connect-offsets-8, connect-offsets-2, connect-offsets-12, connect-offsets-19, connect-offsets-14, connect-offsets-1, connect-offsets-6, connect-offsets-7, connect-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1090)
560[2019-05-15 13:26:44,412] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
561[2019-05-15 13:26:44,414] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
562[2019-05-15 13:26:44,447] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-10 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
563[2019-05-15 13:26:44,449] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-8 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
564[2019-05-15 13:26:44,449] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-14 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
565[2019-05-15 13:26:44,449] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-12 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
566[2019-05-15 13:26:44,449] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
567[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
568[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-6 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
569[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-4 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
570[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-24 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
571[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-18 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
572[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-16 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
573[2019-05-15 13:26:44,450] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-22 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
574[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-20 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
575[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-9 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
576[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-7 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
577[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-13 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
578[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-11 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
579[2019-05-15 13:26:44,451] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
580[2019-05-15 13:26:44,452] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-5 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
581[2019-05-15 13:26:44,452] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-3 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
582[2019-05-15 13:26:44,452] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-23 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
583[2019-05-15 13:26:44,452] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-17 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
584[2019-05-15 13:26:44,452] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-15 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
585[2019-05-15 13:26:44,453] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-21 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
586[2019-05-15 13:26:44,453] INFO [Consumer clientId=consumer-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-19 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
587[2019-05-15 13:26:44,454] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:158)
588[2019-05-15 13:26:44,455] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:160)
589[2019-05-15 13:26:44,455] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110)
590[2019-05-15 13:26:44,456] INFO Worker started (org.apache.kafka.connect.runtime.Worker:167)
591[2019-05-15 13:26:44,457] INFO Starting KafkaBasedLog with topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:125)
592[2019-05-15 13:26:44,457] INFO AdminClientConfig values:
593 bootstrap.servers = [localhost:9092]
594 client.dns.lookup = default
595 client.id =
596 connections.max.idle.ms = 300000
597 metadata.max.age.ms = 300000
598 metric.reporters = []
599 metrics.num.samples = 2
600 metrics.recording.level = INFO
601 metrics.sample.window.ms = 30000
602 receive.buffer.bytes = 65536
603 reconnect.backoff.max.ms = 1000
604 reconnect.backoff.ms = 50
605 request.timeout.ms = 120000
606 retries = 5
607 retry.backoff.ms = 100
608 sasl.client.callback.handler.class = null
609 sasl.jaas.config = null
610 sasl.kerberos.kinit.cmd = /usr/bin/kinit
611 sasl.kerberos.min.time.before.relogin = 60000
612 sasl.kerberos.service.name = null
613 sasl.kerberos.ticket.renew.jitter = 0.05
614 sasl.kerberos.ticket.renew.window.factor = 0.8
615 sasl.login.callback.handler.class = null
616 sasl.login.class = null
617 sasl.login.refresh.buffer.seconds = 300
618 sasl.login.refresh.min.period.seconds = 60
619 sasl.login.refresh.window.factor = 0.8
620 sasl.login.refresh.window.jitter = 0.05
621 sasl.mechanism = GSSAPI
622 security.protocol = PLAINTEXT
623 send.buffer.bytes = 131072
624 ssl.cipher.suites = null
625 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
626 ssl.endpoint.identification.algorithm = https
627 ssl.key.password = null
628 ssl.keymanager.algorithm = SunX509
629 ssl.keystore.location = null
630 ssl.keystore.password = null
631 ssl.keystore.type = JKS
632 ssl.protocol = TLS
633 ssl.provider = null
634 ssl.secure.random.implementation = null
635 ssl.trustmanager.algorithm = PKIX
636 ssl.truststore.location = null
637 ssl.truststore.password = null
638 ssl.truststore.type = JKS
639 (org.apache.kafka.clients.admin.AdminClientConfig:279)
640[2019-05-15 13:26:44,463] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
641[2019-05-15 13:26:44,463] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
642[2019-05-15 13:26:44,463] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
643[2019-05-15 13:26:44,463] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
644[2019-05-15 13:26:44,463] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
645[2019-05-15 13:26:44,464] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
646[2019-05-15 13:26:44,464] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
647[2019-05-15 13:26:44,464] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
648[2019-05-15 13:26:44,464] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
649[2019-05-15 13:26:44,464] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
650[2019-05-15 13:26:44,464] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
651[2019-05-15 13:26:44,464] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
652[2019-05-15 13:26:44,464] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
653[2019-05-15 13:26:44,465] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
654[2019-05-15 13:26:44,466] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
655[2019-05-15 13:26:44,466] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
656[2019-05-15 13:26:44,466] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
657[2019-05-15 13:26:44,467] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
658[2019-05-15 13:26:44,604] INFO Created topic (name=connect-statuses, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:229)
659[2019-05-15 13:26:44,608] INFO ProducerConfig values:
660 acks = all
661 batch.size = 16384
662 bootstrap.servers = [localhost:9092]
663 buffer.memory = 33554432
664 client.dns.lookup = default
665 client.id =
666 compression.type = none
667 connections.max.idle.ms = 540000
668 delivery.timeout.ms = 120000
669 enable.idempotence = false
670 interceptor.classes = []
671 key.serializer = class org.apache.kafka.common.serialization.StringSerializer
672 linger.ms = 0
673 max.block.ms = 60000
674 max.in.flight.requests.per.connection = 1
675 max.request.size = 1048576
676 metadata.max.age.ms = 300000
677 metric.reporters = []
678 metrics.num.samples = 2
679 metrics.recording.level = INFO
680 metrics.sample.window.ms = 30000
681 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
682 receive.buffer.bytes = 32768
683 reconnect.backoff.max.ms = 1000
684 reconnect.backoff.ms = 50
685 request.timeout.ms = 30000
686 retries = 0
687 retry.backoff.ms = 100
688 sasl.client.callback.handler.class = null
689 sasl.jaas.config = null
690 sasl.kerberos.kinit.cmd = /usr/bin/kinit
691 sasl.kerberos.min.time.before.relogin = 60000
692 sasl.kerberos.service.name = null
693 sasl.kerberos.ticket.renew.jitter = 0.05
694 sasl.kerberos.ticket.renew.window.factor = 0.8
695 sasl.login.callback.handler.class = null
696 sasl.login.class = null
697 sasl.login.refresh.buffer.seconds = 300
698 sasl.login.refresh.min.period.seconds = 60
699 sasl.login.refresh.window.factor = 0.8
700 sasl.login.refresh.window.jitter = 0.05
701 sasl.mechanism = GSSAPI
702 security.protocol = PLAINTEXT
703 send.buffer.bytes = 131072
704 ssl.cipher.suites = null
705 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
706 ssl.endpoint.identification.algorithm = https
707 ssl.key.password = null
708 ssl.keymanager.algorithm = SunX509
709 ssl.keystore.location = null
710 ssl.keystore.password = null
711 ssl.keystore.type = JKS
712 ssl.protocol = TLS
713 ssl.provider = null
714 ssl.secure.random.implementation = null
715 ssl.trustmanager.algorithm = PKIX
716 ssl.truststore.location = null
717 ssl.truststore.password = null
718 ssl.truststore.type = JKS
719 transaction.timeout.ms = 60000
720 transactional.id = null
721 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
722 (org.apache.kafka.clients.producer.ProducerConfig:279)
723[2019-05-15 13:26:44,612] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
724[2019-05-15 13:26:44,613] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
725[2019-05-15 13:26:44,613] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
726[2019-05-15 13:26:44,613] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
727[2019-05-15 13:26:44,613] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
728[2019-05-15 13:26:44,613] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
729[2019-05-15 13:26:44,614] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
730[2019-05-15 13:26:44,614] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
731[2019-05-15 13:26:44,614] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
732[2019-05-15 13:26:44,614] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
733[2019-05-15 13:26:44,614] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
734[2019-05-15 13:26:44,616] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
735[2019-05-15 13:26:44,617] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
736[2019-05-15 13:26:44,617] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
737[2019-05-15 13:26:44,617] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
738[2019-05-15 13:26:44,617] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
739[2019-05-15 13:26:44,617] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
740[2019-05-15 13:26:44,618] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
741[2019-05-15 13:26:44,619] INFO ConsumerConfig values:
742 auto.commit.interval.ms = 5000
743 auto.offset.reset = earliest
744 bootstrap.servers = [localhost:9092]
745 check.crcs = true
746 client.dns.lookup = default
747 client.id =
748 connections.max.idle.ms = 540000
749 default.api.timeout.ms = 60000
750 enable.auto.commit = false
751 exclude.internal.topics = true
752 fetch.max.bytes = 52428800
753 fetch.max.wait.ms = 500
754 fetch.min.bytes = 1
755 group.id = connect-cluster
756 heartbeat.interval.ms = 3000
757 interceptor.classes = []
758 internal.leave.group.on.close = true
759 isolation.level = read_uncommitted
760 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
761 max.partition.fetch.bytes = 1048576
762 max.poll.interval.ms = 300000
763 max.poll.records = 500
764 metadata.max.age.ms = 300000
765 metric.reporters = []
766 metrics.num.samples = 2
767 metrics.recording.level = INFO
768 metrics.sample.window.ms = 30000
769 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
770 receive.buffer.bytes = 65536
771 reconnect.backoff.max.ms = 1000
772 reconnect.backoff.ms = 50
773 request.timeout.ms = 30000
774 retry.backoff.ms = 100
775 sasl.client.callback.handler.class = null
776 sasl.jaas.config = null
777 sasl.kerberos.kinit.cmd = /usr/bin/kinit
778 sasl.kerberos.min.time.before.relogin = 60000
779 sasl.kerberos.service.name = null
780 sasl.kerberos.ticket.renew.jitter = 0.05
781 sasl.kerberos.ticket.renew.window.factor = 0.8
782 sasl.login.callback.handler.class = null
783 sasl.login.class = null
784 sasl.login.refresh.buffer.seconds = 300
785 sasl.login.refresh.min.period.seconds = 60
786 sasl.login.refresh.window.factor = 0.8
787 sasl.login.refresh.window.jitter = 0.05
788 sasl.mechanism = GSSAPI
789 security.protocol = PLAINTEXT
790 send.buffer.bytes = 131072
791 session.timeout.ms = 10000
792 ssl.cipher.suites = null
793 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
794 ssl.endpoint.identification.algorithm = https
795 ssl.key.password = null
796 ssl.keymanager.algorithm = SunX509
797 ssl.keystore.location = null
798 ssl.keystore.password = null
799 ssl.keystore.type = JKS
800 ssl.protocol = TLS
801 ssl.provider = null
802 ssl.secure.random.implementation = null
803 ssl.trustmanager.algorithm = PKIX
804 ssl.truststore.location = null
805 ssl.truststore.password = null
806 ssl.truststore.type = JKS
807 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
808 (org.apache.kafka.clients.consumer.ConsumerConfig:279)
809[2019-05-15 13:26:44,625] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
810[2019-05-15 13:26:44,626] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
811[2019-05-15 13:26:44,626] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
812[2019-05-15 13:26:44,626] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
813[2019-05-15 13:26:44,627] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
814[2019-05-15 13:26:44,627] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
815[2019-05-15 13:26:44,627] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
816[2019-05-15 13:26:44,627] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
817[2019-05-15 13:26:44,627] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
818[2019-05-15 13:26:44,628] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
819[2019-05-15 13:26:44,628] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
820[2019-05-15 13:26:44,628] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
821[2019-05-15 13:26:44,628] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
822[2019-05-15 13:26:44,628] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
823[2019-05-15 13:26:44,628] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
824[2019-05-15 13:26:44,628] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
825[2019-05-15 13:26:44,628] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
826[2019-05-15 13:26:44,642] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Subscribed to partition(s): connect-statuses-0, connect-statuses-4, connect-statuses-1, connect-statuses-2, connect-statuses-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1090)
827[2019-05-15 13:26:44,645] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
828[2019-05-15 13:26:44,663] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
829[2019-05-15 13:26:44,663] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-3 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
830[2019-05-15 13:26:44,663] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-4 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
831[2019-05-15 13:26:44,664] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-1 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
832[2019-05-15 13:26:44,664] INFO [Consumer clientId=consumer-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-2 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
833[2019-05-15 13:26:44,664] INFO Finished reading KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:158)
834[2019-05-15 13:26:44,664] INFO Started KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:160)
835[2019-05-15 13:26:44,665] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:248)
836[2019-05-15 13:26:44,665] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:125)
837[2019-05-15 13:26:44,666] INFO AdminClientConfig values:
838 bootstrap.servers = [localhost:9092]
839 client.dns.lookup = default
840 client.id =
841 connections.max.idle.ms = 300000
842 metadata.max.age.ms = 300000
843 metric.reporters = []
844 metrics.num.samples = 2
845 metrics.recording.level = INFO
846 metrics.sample.window.ms = 30000
847 receive.buffer.bytes = 65536
848 reconnect.backoff.max.ms = 1000
849 reconnect.backoff.ms = 50
850 request.timeout.ms = 120000
851 retries = 5
852 retry.backoff.ms = 100
853 sasl.client.callback.handler.class = null
854 sasl.jaas.config = null
855 sasl.kerberos.kinit.cmd = /usr/bin/kinit
856 sasl.kerberos.min.time.before.relogin = 60000
857 sasl.kerberos.service.name = null
858 sasl.kerberos.ticket.renew.jitter = 0.05
859 sasl.kerberos.ticket.renew.window.factor = 0.8
860 sasl.login.callback.handler.class = null
861 sasl.login.class = null
862 sasl.login.refresh.buffer.seconds = 300
863 sasl.login.refresh.min.period.seconds = 60
864 sasl.login.refresh.window.factor = 0.8
865 sasl.login.refresh.window.jitter = 0.05
866 sasl.mechanism = GSSAPI
867 security.protocol = PLAINTEXT
868 send.buffer.bytes = 131072
869 ssl.cipher.suites = null
870 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
871 ssl.endpoint.identification.algorithm = https
872 ssl.key.password = null
873 ssl.keymanager.algorithm = SunX509
874 ssl.keystore.location = null
875 ssl.keystore.password = null
876 ssl.keystore.type = JKS
877 ssl.protocol = TLS
878 ssl.provider = null
879 ssl.secure.random.implementation = null
880 ssl.trustmanager.algorithm = PKIX
881 ssl.truststore.location = null
882 ssl.truststore.password = null
883 ssl.truststore.type = JKS
884 (org.apache.kafka.clients.admin.AdminClientConfig:279)
885[2019-05-15 13:26:44,671] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
886[2019-05-15 13:26:44,671] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
887[2019-05-15 13:26:44,671] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
888[2019-05-15 13:26:44,671] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
889[2019-05-15 13:26:44,671] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
890[2019-05-15 13:26:44,671] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
891[2019-05-15 13:26:44,672] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
892[2019-05-15 13:26:44,672] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
893[2019-05-15 13:26:44,672] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
894[2019-05-15 13:26:44,672] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
895[2019-05-15 13:26:44,672] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
896[2019-05-15 13:26:44,672] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
897[2019-05-15 13:26:44,672] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
898[2019-05-15 13:26:44,672] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
899[2019-05-15 13:26:44,673] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
900[2019-05-15 13:26:44,673] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
901[2019-05-15 13:26:44,673] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
902[2019-05-15 13:26:44,673] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
903[2019-05-15 13:26:44,718] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
904[2019-05-15 13:26:44,749] INFO Created topic (name=connect-configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:229)
905[2019-05-15 13:26:44,752] INFO ProducerConfig values:
906 acks = all
907 batch.size = 16384
908 bootstrap.servers = [localhost:9092]
909 buffer.memory = 33554432
910 client.dns.lookup = default
911 client.id =
912 compression.type = none
913 connections.max.idle.ms = 540000
914 delivery.timeout.ms = 2147483647
915 enable.idempotence = false
916 interceptor.classes = []
917 key.serializer = class org.apache.kafka.common.serialization.StringSerializer
918 linger.ms = 0
919 max.block.ms = 60000
920 max.in.flight.requests.per.connection = 1
921 max.request.size = 1048576
922 metadata.max.age.ms = 300000
923 metric.reporters = []
924 metrics.num.samples = 2
925 metrics.recording.level = INFO
926 metrics.sample.window.ms = 30000
927 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
928 receive.buffer.bytes = 32768
929 reconnect.backoff.max.ms = 1000
930 reconnect.backoff.ms = 50
931 request.timeout.ms = 30000
932 retries = 2147483647
933 retry.backoff.ms = 100
934 sasl.client.callback.handler.class = null
935 sasl.jaas.config = null
936 sasl.kerberos.kinit.cmd = /usr/bin/kinit
937 sasl.kerberos.min.time.before.relogin = 60000
938 sasl.kerberos.service.name = null
939 sasl.kerberos.ticket.renew.jitter = 0.05
940 sasl.kerberos.ticket.renew.window.factor = 0.8
941 sasl.login.callback.handler.class = null
942 sasl.login.class = null
943 sasl.login.refresh.buffer.seconds = 300
944 sasl.login.refresh.min.period.seconds = 60
945 sasl.login.refresh.window.factor = 0.8
946 sasl.login.refresh.window.jitter = 0.05
947 sasl.mechanism = GSSAPI
948 security.protocol = PLAINTEXT
949 send.buffer.bytes = 131072
950 ssl.cipher.suites = null
951 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
952 ssl.endpoint.identification.algorithm = https
953 ssl.key.password = null
954 ssl.keymanager.algorithm = SunX509
955 ssl.keystore.location = null
956 ssl.keystore.password = null
957 ssl.keystore.type = JKS
958 ssl.protocol = TLS
959 ssl.provider = null
960 ssl.secure.random.implementation = null
961 ssl.trustmanager.algorithm = PKIX
962 ssl.truststore.location = null
963 ssl.truststore.password = null
964 ssl.truststore.type = JKS
965 transaction.timeout.ms = 60000
966 transactional.id = null
967 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
968 (org.apache.kafka.clients.producer.ProducerConfig:279)
969[2019-05-15 13:26:44,759] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
970[2019-05-15 13:26:44,759] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
971[2019-05-15 13:26:44,759] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
972[2019-05-15 13:26:44,759] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
973[2019-05-15 13:26:44,759] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
974[2019-05-15 13:26:44,759] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
975[2019-05-15 13:26:44,760] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
976[2019-05-15 13:26:44,760] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
977[2019-05-15 13:26:44,760] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
978[2019-05-15 13:26:44,760] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
979[2019-05-15 13:26:44,760] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
980[2019-05-15 13:26:44,760] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
981[2019-05-15 13:26:44,760] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
982[2019-05-15 13:26:44,760] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
983[2019-05-15 13:26:44,760] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
984[2019-05-15 13:26:44,760] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:287)
985[2019-05-15 13:26:44,760] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
986[2019-05-15 13:26:44,761] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
987[2019-05-15 13:26:44,761] INFO ConsumerConfig values:
988 auto.commit.interval.ms = 5000
989 auto.offset.reset = earliest
990 bootstrap.servers = [localhost:9092]
991 check.crcs = true
992 client.dns.lookup = default
993 client.id =
994 connections.max.idle.ms = 540000
995 default.api.timeout.ms = 60000
996 enable.auto.commit = false
997 exclude.internal.topics = true
998 fetch.max.bytes = 52428800
999 fetch.max.wait.ms = 500
1000 fetch.min.bytes = 1
1001 group.id = connect-cluster
1002 heartbeat.interval.ms = 3000
1003 interceptor.classes = []
1004 internal.leave.group.on.close = true
1005 isolation.level = read_uncommitted
1006 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
1007 max.partition.fetch.bytes = 1048576
1008 max.poll.interval.ms = 300000
1009 max.poll.records = 500
1010 metadata.max.age.ms = 300000
1011 metric.reporters = []
1012 metrics.num.samples = 2
1013 metrics.recording.level = INFO
1014 metrics.sample.window.ms = 30000
1015 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
1016 receive.buffer.bytes = 65536
1017 reconnect.backoff.max.ms = 1000
1018 reconnect.backoff.ms = 50
1019 request.timeout.ms = 30000
1020 retry.backoff.ms = 100
1021 sasl.client.callback.handler.class = null
1022 sasl.jaas.config = null
1023 sasl.kerberos.kinit.cmd = /usr/bin/kinit
1024 sasl.kerberos.min.time.before.relogin = 60000
1025 sasl.kerberos.service.name = null
1026 sasl.kerberos.ticket.renew.jitter = 0.05
1027 sasl.kerberos.ticket.renew.window.factor = 0.8
1028 sasl.login.callback.handler.class = null
1029 sasl.login.class = null
1030 sasl.login.refresh.buffer.seconds = 300
1031 sasl.login.refresh.min.period.seconds = 60
1032 sasl.login.refresh.window.factor = 0.8
1033 sasl.login.refresh.window.jitter = 0.05
1034 sasl.mechanism = GSSAPI
1035 security.protocol = PLAINTEXT
1036 send.buffer.bytes = 131072
1037 session.timeout.ms = 10000
1038 ssl.cipher.suites = null
1039 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
1040 ssl.endpoint.identification.algorithm = https
1041 ssl.key.password = null
1042 ssl.keymanager.algorithm = SunX509
1043 ssl.keystore.location = null
1044 ssl.keystore.password = null
1045 ssl.keystore.type = JKS
1046 ssl.protocol = TLS
1047 ssl.provider = null
1048 ssl.secure.random.implementation = null
1049 ssl.trustmanager.algorithm = PKIX
1050 ssl.truststore.location = null
1051 ssl.truststore.password = null
1052 ssl.truststore.type = JKS
1053 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
1054 (org.apache.kafka.clients.consumer.ConsumerConfig:279)
1055[2019-05-15 13:26:44,766] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1056[2019-05-15 13:26:44,767] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1057[2019-05-15 13:26:44,767] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1058[2019-05-15 13:26:44,767] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1059[2019-05-15 13:26:44,767] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1060[2019-05-15 13:26:44,767] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1061[2019-05-15 13:26:44,767] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1062[2019-05-15 13:26:44,767] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1063[2019-05-15 13:26:44,767] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1064[2019-05-15 13:26:44,767] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1065[2019-05-15 13:26:44,767] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1066[2019-05-15 13:26:44,767] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1067[2019-05-15 13:26:44,768] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1068[2019-05-15 13:26:44,768] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1069[2019-05-15 13:26:44,768] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:287)
1070[2019-05-15 13:26:44,768] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
1071[2019-05-15 13:26:44,768] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
1072[2019-05-15 13:26:44,783] INFO [Consumer clientId=consumer-3, groupId=connect-cluster] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1090)
1073[2019-05-15 13:26:44,786] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
1074[2019-05-15 13:26:44,794] INFO [Consumer clientId=consumer-3, groupId=connect-cluster] Resetting offset for partition connect-configs-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher:584)
1075[2019-05-15 13:26:44,794] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:158)
1076[2019-05-15 13:26:44,794] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:160)
1077[2019-05-15 13:26:44,795] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:253)
1078[2019-05-15 13:26:44,795] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:216)
1079[2019-05-15 13:26:44,804] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
1080[2019-05-15 13:26:44,871] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
1081[2019-05-15 13:26:45,953] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator 192.168.1.5:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:675)
1082[2019-05-15 13:26:45,955] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491)
1083[2019-05-15 13:26:45,983] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491)
1084[2019-05-15 13:26:46,045] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
1085[2019-05-15 13:26:46,047] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-4ecec8bd-72d4-4819-86e8-e231e7f474e5', leaderUrl='http://192.168.1.5:8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216)
1086[2019-05-15 13:26:46,048] INFO Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
1087[2019-05-15 13:26:46,048] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
1088[2019-05-15 13:26:52,188] INFO 0:0:0:0:0:0:0:1 - - [15/May/2019:07:56:51 +0000] "GET /connectors HTTP/1.1" 200 2 199 (org.apache.kafka.connect.runtime.rest.RestServer:60)
1089[2019-05-15 13:27:00,275] INFO Successfully tested connection for jdbc:mysql://localhost:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL with user 'debezium' (io.debezium.connector.mysql.MySqlConnector:102)
1090[2019-05-15 13:27:00,357] INFO Connector cdc-lav config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1097)
1091[2019-05-15 13:27:00,856] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238)
1092[2019-05-15 13:27:00,856] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268)
1093[2019-05-15 13:27:00,856] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491)
1094[2019-05-15 13:27:00,878] INFO 0:0:0:0:0:0:0:1 - - [15/May/2019:07:56:59 +0000] "POST /connectors HTTP/1.1" 201 830 1070 (org.apache.kafka.connect.runtime.rest.RestServer:60)
1095[2019-05-15 13:27:00,907] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
1096[2019-05-15 13:27:00,907] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-4ecec8bd-72d4-4819-86e8-e231e7f474e5', leaderUrl='http://192.168.1.5:8083/', offset=1, connectorIds=[cdc-lav], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216)
1097[2019-05-15 13:27:00,907] INFO Starting connectors and tasks using config offset 1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
1098[2019-05-15 13:27:00,908] INFO Starting connector cdc-lav (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904)
1099[2019-05-15 13:27:00,909] INFO ConnectorConfig values:
1100 config.action.reload = restart
1101 connector.class = io.debezium.connector.mysql.MySqlConnector
1102 errors.log.enable = false
1103 errors.log.include.messages = false
1104 errors.retry.delay.max.ms = 60000
1105 errors.retry.timeout = 0
1106 errors.tolerance = none
1107 header.converter = null
1108 key.converter = class org.apache.kafka.connect.json.JsonConverter
1109 name = cdc-lav
1110 tasks.max = 1
1111 transforms = []
1112 value.converter = class org.apache.kafka.connect.json.JsonConverter
1113 (org.apache.kafka.connect.runtime.ConnectorConfig:279)
1114[2019-05-15 13:27:00,910] INFO EnrichedConnectorConfig values:
1115 config.action.reload = restart
1116 connector.class = io.debezium.connector.mysql.MySqlConnector
1117 errors.log.enable = false
1118 errors.log.include.messages = false
1119 errors.retry.delay.max.ms = 60000
1120 errors.retry.timeout = 0
1121 errors.tolerance = none
1122 header.converter = null
1123 key.converter = class org.apache.kafka.connect.json.JsonConverter
1124 name = cdc-lav
1125 tasks.max = 1
1126 transforms = []
1127 value.converter = class org.apache.kafka.connect.json.JsonConverter
1128 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
1129[2019-05-15 13:27:00,910] INFO Creating connector cdc-lav of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:225)
1130[2019-05-15 13:27:00,913] INFO Instantiated connector cdc-lav with version 0.9.4.Final of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:228)
1131[2019-05-15 13:27:00,923] INFO Finished creating connector cdc-lav (org.apache.kafka.connect.runtime.Worker:247)
1132[2019-05-15 13:27:00,924] INFO SourceConnectorConfig values:
1133 config.action.reload = restart
1134 connector.class = io.debezium.connector.mysql.MySqlConnector
1135 errors.log.enable = false
1136 errors.log.include.messages = false
1137 errors.retry.delay.max.ms = 60000
1138 errors.retry.timeout = 0
1139 errors.tolerance = none
1140 header.converter = null
1141 key.converter = class org.apache.kafka.connect.json.JsonConverter
1142 name = cdc-lav
1143 tasks.max = 1
1144 transforms = []
1145 value.converter = class org.apache.kafka.connect.json.JsonConverter
1146 (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)
1147[2019-05-15 13:27:00,925] INFO EnrichedConnectorConfig values:
1148 config.action.reload = restart
1149 connector.class = io.debezium.connector.mysql.MySqlConnector
1150 errors.log.enable = false
1151 errors.log.include.messages = false
1152 errors.retry.delay.max.ms = 60000
1153 errors.retry.timeout = 0
1154 errors.tolerance = none
1155 header.converter = null
1156 key.converter = class org.apache.kafka.connect.json.JsonConverter
1157 name = cdc-lav
1158 tasks.max = 1
1159 transforms = []
1160 value.converter = class org.apache.kafka.connect.json.JsonConverter
1161 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
1162[2019-05-15 13:27:01,873] INFO Tasks [cdc-lav-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1112)
1163[2019-05-15 13:27:02,376] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
1164[2019-05-15 13:27:02,377] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238)
1165[2019-05-15 13:27:02,378] INFO Stopping connector cdc-lav (org.apache.kafka.connect.runtime.Worker:328)
1166[2019-05-15 13:27:02,379] INFO Stopped connector cdc-lav (org.apache.kafka.connect.runtime.Worker:344)
1167[2019-05-15 13:27:02,382] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268)
1168[2019-05-15 13:27:02,382] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:491)
1169[2019-05-15 13:27:02,387] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 3 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:455)
1170[2019-05-15 13:27:02,388] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-4ecec8bd-72d4-4819-86e8-e231e7f474e5', leaderUrl='http://192.168.1.5:8083/', offset=3, connectorIds=[cdc-lav], taskIds=[cdc-lav-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1216)
1171[2019-05-15 13:27:02,388] INFO Starting connectors and tasks using config offset 3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
1172[2019-05-15 13:27:02,389] INFO Starting connector cdc-lav (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904)
1173[2019-05-15 13:27:02,389] INFO Starting task cdc-lav-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864)
1174[2019-05-15 13:27:02,389] INFO ConnectorConfig values:
1175 config.action.reload = restart
1176 connector.class = io.debezium.connector.mysql.MySqlConnector
1177 errors.log.enable = false
1178 errors.log.include.messages = false
1179 errors.retry.delay.max.ms = 60000
1180 errors.retry.timeout = 0
1181 errors.tolerance = none
1182 header.converter = null
1183 key.converter = class org.apache.kafka.connect.json.JsonConverter
1184 name = cdc-lav
1185 tasks.max = 1
1186 transforms = []
1187 value.converter = class org.apache.kafka.connect.json.JsonConverter
1188 (org.apache.kafka.connect.runtime.ConnectorConfig:279)
1189[2019-05-15 13:27:02,389] INFO Creating task cdc-lav-0 (org.apache.kafka.connect.runtime.Worker:386)
1190[2019-05-15 13:27:02,389] INFO EnrichedConnectorConfig values:
1191 config.action.reload = restart
1192 connector.class = io.debezium.connector.mysql.MySqlConnector
1193 errors.log.enable = false
1194 errors.log.include.messages = false
1195 errors.retry.delay.max.ms = 60000
1196 errors.retry.timeout = 0
1197 errors.tolerance = none
1198 header.converter = null
1199 key.converter = class org.apache.kafka.connect.json.JsonConverter
1200 name = cdc-lav
1201 tasks.max = 1
1202 transforms = []
1203 value.converter = class org.apache.kafka.connect.json.JsonConverter
1204 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
1205[2019-05-15 13:27:02,390] INFO ConnectorConfig values:
1206 config.action.reload = restart
1207 connector.class = io.debezium.connector.mysql.MySqlConnector
1208 errors.log.enable = false
1209 errors.log.include.messages = false
1210 errors.retry.delay.max.ms = 60000
1211 errors.retry.timeout = 0
1212 errors.tolerance = none
1213 header.converter = null
1214 key.converter = class org.apache.kafka.connect.json.JsonConverter
1215 name = cdc-lav
1216 tasks.max = 1
1217 transforms = []
1218 value.converter = class org.apache.kafka.connect.json.JsonConverter
1219 (org.apache.kafka.connect.runtime.ConnectorConfig:279)
1220[2019-05-15 13:27:02,390] INFO Creating connector cdc-lav of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:225)
1221[2019-05-15 13:27:02,390] INFO EnrichedConnectorConfig values:
1222 config.action.reload = restart
1223 connector.class = io.debezium.connector.mysql.MySqlConnector
1224 errors.log.enable = false
1225 errors.log.include.messages = false
1226 errors.retry.delay.max.ms = 60000
1227 errors.retry.timeout = 0
1228 errors.tolerance = none
1229 header.converter = null
1230 key.converter = class org.apache.kafka.connect.json.JsonConverter
1231 name = cdc-lav
1232 tasks.max = 1
1233 transforms = []
1234 value.converter = class org.apache.kafka.connect.json.JsonConverter
1235 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
1236[2019-05-15 13:27:02,391] INFO Instantiated connector cdc-lav with version 0.9.4.Final of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:228)
1237[2019-05-15 13:27:02,391] INFO Finished creating connector cdc-lav (org.apache.kafka.connect.runtime.Worker:247)
1238[2019-05-15 13:27:02,392] INFO SourceConnectorConfig values:
1239 config.action.reload = restart
1240 connector.class = io.debezium.connector.mysql.MySqlConnector
1241 errors.log.enable = false
1242 errors.log.include.messages = false
1243 errors.retry.delay.max.ms = 60000
1244 errors.retry.timeout = 0
1245 errors.tolerance = none
1246 header.converter = null
1247 key.converter = class org.apache.kafka.connect.json.JsonConverter
1248 name = cdc-lav
1249 tasks.max = 1
1250 transforms = []
1251 value.converter = class org.apache.kafka.connect.json.JsonConverter
1252 (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)
1253[2019-05-15 13:27:02,392] INFO TaskConfig values:
1254 task.class = class io.debezium.connector.mysql.MySqlConnectorTask
1255 (org.apache.kafka.connect.runtime.TaskConfig:279)
1256[2019-05-15 13:27:02,392] INFO EnrichedConnectorConfig values:
1257 config.action.reload = restart
1258 connector.class = io.debezium.connector.mysql.MySqlConnector
1259 errors.log.enable = false
1260 errors.log.include.messages = false
1261 errors.retry.delay.max.ms = 60000
1262 errors.retry.timeout = 0
1263 errors.tolerance = none
1264 header.converter = null
1265 key.converter = class org.apache.kafka.connect.json.JsonConverter
1266 name = cdc-lav
1267 tasks.max = 1
1268 transforms = []
1269 value.converter = class org.apache.kafka.connect.json.JsonConverter
1270 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
1271[2019-05-15 13:27:02,393] INFO Instantiated task cdc-lav-0 with version 0.9.4.Final of type io.debezium.connector.mysql.MySqlConnectorTask (org.apache.kafka.connect.runtime.Worker:401)
1272[2019-05-15 13:27:02,393] INFO JsonConverterConfig values:
1273 converter.type = key
1274 schemas.cache.size = 1000
1275 schemas.enable = false
1276 (org.apache.kafka.connect.json.JsonConverterConfig:279)
1277[2019-05-15 13:27:02,394] INFO JsonConverterConfig values:
1278 converter.type = value
1279 schemas.cache.size = 1000
1280 schemas.enable = false
1281 (org.apache.kafka.connect.json.JsonConverterConfig:279)
1282[2019-05-15 13:27:02,394] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task cdc-lav-0 using the connector config (org.apache.kafka.connect.runtime.Worker:426)
1283[2019-05-15 13:27:02,394] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task cdc-lav-0 using the connector config (org.apache.kafka.connect.runtime.Worker:432)
1284[2019-05-15 13:27:02,395] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task cdc-lav-0 using the worker config (org.apache.kafka.connect.runtime.Worker:436)
1285[2019-05-15 13:27:02,399] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:486)
1286[2019-05-15 13:27:02,401] INFO ProducerConfig values:
1287 acks = all
1288 batch.size = 16384
1289 bootstrap.servers = [localhost:9092]
1290 buffer.memory = 33554432
1291 client.dns.lookup = default
1292 client.id =
1293 compression.type = none
1294 connections.max.idle.ms = 540000
1295 delivery.timeout.ms = 2147483647
1296 enable.idempotence = false
1297 interceptor.classes = []
1298 key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
1299 linger.ms = 0
1300 max.block.ms = 9223372036854775807
1301 max.in.flight.requests.per.connection = 1
1302 max.request.size = 1048576
1303 metadata.max.age.ms = 300000
1304 metric.reporters = []
1305 metrics.num.samples = 2
1306 metrics.recording.level = INFO
1307 metrics.sample.window.ms = 30000
1308 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
1309 receive.buffer.bytes = 32768
1310 reconnect.backoff.max.ms = 1000
1311 reconnect.backoff.ms = 50
1312 request.timeout.ms = 2147483647
1313 retries = 2147483647
1314 retry.backoff.ms = 100
1315 sasl.client.callback.handler.class = null
1316 sasl.jaas.config = null
1317 sasl.kerberos.kinit.cmd = /usr/bin/kinit
1318 sasl.kerberos.min.time.before.relogin = 60000
1319 sasl.kerberos.service.name = null
1320 sasl.kerberos.ticket.renew.jitter = 0.05
1321 sasl.kerberos.ticket.renew.window.factor = 0.8
1322 sasl.login.callback.handler.class = null
1323 sasl.login.class = null
1324 sasl.login.refresh.buffer.seconds = 300
1325 sasl.login.refresh.min.period.seconds = 60
1326 sasl.login.refresh.window.factor = 0.8
1327 sasl.login.refresh.window.jitter = 0.05
1328 sasl.mechanism = GSSAPI
1329 security.protocol = PLAINTEXT
1330 send.buffer.bytes = 131072
1331 ssl.cipher.suites = null
1332 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
1333 ssl.endpoint.identification.algorithm = https
1334 ssl.key.password = null
1335 ssl.keymanager.algorithm = SunX509
1336 ssl.keystore.location = null
1337 ssl.keystore.password = null
1338 ssl.keystore.type = JKS
1339 ssl.protocol = TLS
1340 ssl.provider = null
1341 ssl.secure.random.implementation = null
1342 ssl.trustmanager.algorithm = PKIX
1343 ssl.truststore.location = null
1344 ssl.truststore.password = null
1345 ssl.truststore.type = JKS
1346 transaction.timeout.ms = 60000
1347 transactional.id = null
1348 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
1349 (org.apache.kafka.clients.producer.ProducerConfig:279)
1350[2019-05-15 13:27:02,404] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
1351[2019-05-15 13:27:02,404] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
1352[2019-05-15 13:27:02,410] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
1353[2019-05-15 13:27:02,413] INFO Starting MySqlConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:43)
1354[2019-05-15 13:27:02,415] INFO connector.class = io.debezium.connector.mysql.MySqlConnector (io.debezium.connector.common.BaseSourceTask:45)
1355[2019-05-15 13:27:02,415] INFO database.user = debezium (io.debezium.connector.common.BaseSourceTask:45)
1356[2019-05-15 13:27:02,415] INFO database.server.id = 43 (io.debezium.connector.common.BaseSourceTask:45)
1357[2019-05-15 13:27:02,415] INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:45)
1358[2019-05-15 13:27:02,415] INFO database.history.kafka.bootstrap.servers = localhost:9092 (io.debezium.connector.common.BaseSourceTask:45)
1359[2019-05-15 13:27:02,415] INFO database.history.kafka.topic = lav.history (io.debezium.connector.common.BaseSourceTask:45)
1360[2019-05-15 13:27:02,415] INFO database.server.name = cdc-lav (io.debezium.connector.common.BaseSourceTask:45)
1361[2019-05-15 13:27:02,415] INFO database.port = 3306 (io.debezium.connector.common.BaseSourceTask:45)
1362[2019-05-15 13:27:02,415] INFO table.whitelist = aadhaardb.verificationrequestbase,aadhaardb.laverificationrequest,aadhaardb.addressentity,aadhaardb.personnel,aadhaardb.personnelserviceareaentity (io.debezium.connector.common.BaseSourceTask:45)
1363[2019-05-15 13:27:02,416] INFO key.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:45)
1364[2019-05-15 13:27:02,416] INFO task.class = io.debezium.connector.mysql.MySqlConnectorTask (io.debezium.connector.common.BaseSourceTask:45)
1365[2019-05-15 13:27:02,416] INFO database.hostname = localhost (io.debezium.connector.common.BaseSourceTask:45)
1366[2019-05-15 13:27:02,416] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:45)
1367[2019-05-15 13:27:02,416] INFO value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:45)
1368[2019-05-15 13:27:02,416] INFO name = cdc-lav (io.debezium.connector.common.BaseSourceTask:45)
1369[2019-05-15 13:27:02,416] INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:45)
1370[2019-05-15 13:27:02,416] INFO database.whitelist = aadhaardb (io.debezium.connector.common.BaseSourceTask:45)
1371[2019-05-15 13:27:02,416] INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:45)
1372[2019-05-15 13:27:02,505] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
1373[2019-05-15 13:27:02,880] INFO KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=cdc-lav-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=localhost:9092, client.id=cdc-lav-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:164)
1374[2019-05-15 13:27:02,880] INFO KafkaDatabaseHistory Producer config: {bootstrap.servers=localhost:9092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=cdc-lav-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:165)
1375[2019-05-15 13:27:02,883] INFO ProducerConfig values:
1376 acks = 1
1377 batch.size = 32768
1378 bootstrap.servers = [localhost:9092]
1379 buffer.memory = 1048576
1380 client.dns.lookup = default
1381 client.id = cdc-lav-dbhistory
1382 compression.type = none
1383 connections.max.idle.ms = 540000
1384 delivery.timeout.ms = 120000
1385 enable.idempotence = false
1386 interceptor.classes = []
1387 key.serializer = class org.apache.kafka.common.serialization.StringSerializer
1388 linger.ms = 0
1389 max.block.ms = 10000
1390 max.in.flight.requests.per.connection = 5
1391 max.request.size = 1048576
1392 metadata.max.age.ms = 300000
1393 metric.reporters = []
1394 metrics.num.samples = 2
1395 metrics.recording.level = INFO
1396 metrics.sample.window.ms = 30000
1397 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
1398 receive.buffer.bytes = 32768
1399 reconnect.backoff.max.ms = 1000
1400 reconnect.backoff.ms = 50
1401 request.timeout.ms = 30000
1402 retries = 1
1403 retry.backoff.ms = 100
1404 sasl.client.callback.handler.class = null
1405 sasl.jaas.config = null
1406 sasl.kerberos.kinit.cmd = /usr/bin/kinit
1407 sasl.kerberos.min.time.before.relogin = 60000
1408 sasl.kerberos.service.name = null
1409 sasl.kerberos.ticket.renew.jitter = 0.05
1410 sasl.kerberos.ticket.renew.window.factor = 0.8
1411 sasl.login.callback.handler.class = null
1412 sasl.login.class = null
1413 sasl.login.refresh.buffer.seconds = 300
1414 sasl.login.refresh.min.period.seconds = 60
1415 sasl.login.refresh.window.factor = 0.8
1416 sasl.login.refresh.window.jitter = 0.05
1417 sasl.mechanism = GSSAPI
1418 security.protocol = PLAINTEXT
1419 send.buffer.bytes = 131072
1420 ssl.cipher.suites = null
1421 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
1422 ssl.endpoint.identification.algorithm = https
1423 ssl.key.password = null
1424 ssl.keymanager.algorithm = SunX509
1425 ssl.keystore.location = null
1426 ssl.keystore.password = null
1427 ssl.keystore.type = JKS
1428 ssl.protocol = TLS
1429 ssl.provider = null
1430 ssl.secure.random.implementation = null
1431 ssl.trustmanager.algorithm = PKIX
1432 ssl.truststore.location = null
1433 ssl.truststore.password = null
1434 ssl.truststore.type = JKS
1435 transaction.timeout.ms = 60000
1436 transactional.id = null
1437 value.serializer = class org.apache.kafka.common.serialization.StringSerializer
1438 (org.apache.kafka.clients.producer.ProducerConfig:279)
1439[2019-05-15 13:27:02,886] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
1440[2019-05-15 13:27:02,887] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
1441[2019-05-15 13:27:02,888] INFO AdminClientConfig values:
1442 bootstrap.servers = [localhost:9092]
1443 client.dns.lookup = default
1444 client.id = cdc-lav-dbhistory
1445 connections.max.idle.ms = 300000
1446 metadata.max.age.ms = 300000
1447 metric.reporters = []
1448 metrics.num.samples = 2
1449 metrics.recording.level = INFO
1450 metrics.sample.window.ms = 30000
1451 receive.buffer.bytes = 65536
1452 reconnect.backoff.max.ms = 1000
1453 reconnect.backoff.ms = 50
1454 request.timeout.ms = 120000
1455 retries = 1
1456 retry.backoff.ms = 100
1457 sasl.client.callback.handler.class = null
1458 sasl.jaas.config = null
1459 sasl.kerberos.kinit.cmd = /usr/bin/kinit
1460 sasl.kerberos.min.time.before.relogin = 60000
1461 sasl.kerberos.service.name = null
1462 sasl.kerberos.ticket.renew.jitter = 0.05
1463 sasl.kerberos.ticket.renew.window.factor = 0.8
1464 sasl.login.callback.handler.class = null
1465 sasl.login.class = null
1466 sasl.login.refresh.buffer.seconds = 300
1467 sasl.login.refresh.min.period.seconds = 60
1468 sasl.login.refresh.window.factor = 0.8
1469 sasl.login.refresh.window.jitter = 0.05
1470 sasl.mechanism = GSSAPI
1471 security.protocol = PLAINTEXT
1472 send.buffer.bytes = 131072
1473 ssl.cipher.suites = null
1474 ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
1475 ssl.endpoint.identification.algorithm = https
1476 ssl.key.password = null
1477 ssl.keymanager.algorithm = SunX509
1478 ssl.keystore.location = null
1479 ssl.keystore.password = null
1480 ssl.keystore.type = JKS
1481 ssl.protocol = TLS
1482 ssl.provider = null
1483 ssl.secure.random.implementation = null
1484 ssl.trustmanager.algorithm = PKIX
1485 ssl.truststore.location = null
1486 ssl.truststore.password = null
1487 ssl.truststore.type = JKS
1488 (org.apache.kafka.clients.admin.AdminClientConfig:279)
1489[2019-05-15 13:27:02,891] WARN The configuration 'value.serializer' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1490[2019-05-15 13:27:02,891] WARN The configuration 'batch.size' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1491[2019-05-15 13:27:02,891] WARN The configuration 'max.block.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1492[2019-05-15 13:27:02,891] WARN The configuration 'acks' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1493[2019-05-15 13:27:02,891] WARN The configuration 'buffer.memory' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1494[2019-05-15 13:27:02,892] WARN The configuration 'key.serializer' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1495[2019-05-15 13:27:02,892] WARN The configuration 'linger.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
1496[2019-05-15 13:27:02,892] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
1497[2019-05-15 13:27:02,892] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
1498[2019-05-15 13:27:02,934] INFO Database history topic '(name=lav.history, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created (io.debezium.relational.history.KafkaDatabaseHistory:357)
1499[2019-05-15 13:27:02,992] INFO Found no existing offset, so preparing to perform a snapshot (io.debezium.connector.mysql.MySqlConnectorTask:160)
1500[2019-05-15 13:27:02,994] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
1501[2019-05-15 13:27:03,037] INFO Requested thread factory for connector MySqlConnector, id = cdc-lav named = binlog-client (io.debezium.util.Threads:250)
1502[2019-05-15 13:27:03,048] INFO Requested thread factory for connector MySqlConnector, id = cdc-lav named = snapshot (io.debezium.util.Threads:250)
1503[2019-05-15 13:27:03,049] INFO Creating thread debezium-mysqlconnector-cdc-lav-snapshot (io.debezium.util.Threads:267)
1504[2019-05-15 13:27:03,049] INFO WorkerSourceTask{id=cdc-lav-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:200)
1505[2019-05-15 13:27:03,050] INFO Starting snapshot for jdbc:mysql://localhost:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL with user 'debezium' with locking mode 'minimal' (io.debezium.connector.mysql.SnapshotReader:177)
1506[2019-05-15 13:27:03,052] INFO Snapshot is using user 'debezium' with these MySQL grants: (io.debezium.connector.mysql.SnapshotReader:851)
1507[2019-05-15 13:27:03,053] INFO GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'debezium'@'%' (io.debezium.connector.mysql.SnapshotReader:852)
1508[2019-05-15 13:27:03,053] INFO MySQL server variables related to change data capture: (io.debezium.connector.mysql.SnapshotReader:824)
1509[2019-05-15 13:27:03,062] INFO binlog_cache_size = 32768 (io.debezium.connector.mysql.SnapshotReader:827)
1510[2019-05-15 13:27:03,062] INFO binlog_checksum = CRC32 (io.debezium.connector.mysql.SnapshotReader:827)
1511[2019-05-15 13:27:03,062] INFO binlog_direct_non_transactional_updates = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1512[2019-05-15 13:27:03,062] INFO binlog_error_action = ABORT_SERVER (io.debezium.connector.mysql.SnapshotReader:827)
1513[2019-05-15 13:27:03,062] INFO binlog_format = ROW (io.debezium.connector.mysql.SnapshotReader:827)
1514[2019-05-15 13:27:03,062] INFO binlog_group_commit_sync_delay = 0 (io.debezium.connector.mysql.SnapshotReader:827)
1515[2019-05-15 13:27:03,063] INFO binlog_group_commit_sync_no_delay_count = 0 (io.debezium.connector.mysql.SnapshotReader:827)
1516[2019-05-15 13:27:03,063] INFO binlog_gtid_simple_recovery = ON (io.debezium.connector.mysql.SnapshotReader:827)
1517[2019-05-15 13:27:03,063] INFO binlog_max_flush_queue_time = 0 (io.debezium.connector.mysql.SnapshotReader:827)
1518[2019-05-15 13:27:03,063] INFO binlog_order_commits = ON (io.debezium.connector.mysql.SnapshotReader:827)
1519[2019-05-15 13:27:03,063] INFO binlog_row_image = FULL (io.debezium.connector.mysql.SnapshotReader:827)
1520[2019-05-15 13:27:03,063] INFO binlog_rows_query_log_events = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1521[2019-05-15 13:27:03,063] INFO binlog_stmt_cache_size = 32768 (io.debezium.connector.mysql.SnapshotReader:827)
1522[2019-05-15 13:27:03,063] INFO binlog_transaction_dependency_history_size = 25000 (io.debezium.connector.mysql.SnapshotReader:827)
1523[2019-05-15 13:27:03,063] INFO binlog_transaction_dependency_tracking = COMMIT_ORDER (io.debezium.connector.mysql.SnapshotReader:827)
1524[2019-05-15 13:27:03,063] INFO character_set_client = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
1525[2019-05-15 13:27:03,063] INFO character_set_connection = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
1526[2019-05-15 13:27:03,064] INFO character_set_database = latin1 (io.debezium.connector.mysql.SnapshotReader:827)
1527[2019-05-15 13:27:03,064] INFO character_set_filesystem = binary (io.debezium.connector.mysql.SnapshotReader:827)
1528[2019-05-15 13:27:03,064] INFO character_set_results = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
1529[2019-05-15 13:27:03,064] INFO character_set_server = latin1 (io.debezium.connector.mysql.SnapshotReader:827)
1530[2019-05-15 13:27:03,064] INFO character_set_system = utf8 (io.debezium.connector.mysql.SnapshotReader:827)
1531[2019-05-15 13:27:03,064] INFO character_sets_dir = /usr/local/mysql-5.7.25-macos10.14-x86_64/share/charsets/ (io.debezium.connector.mysql.SnapshotReader:827)
1532[2019-05-15 13:27:03,064] INFO collation_connection = utf8mb4_general_ci (io.debezium.connector.mysql.SnapshotReader:827)
1533[2019-05-15 13:27:03,064] INFO collation_database = latin1_swedish_ci (io.debezium.connector.mysql.SnapshotReader:827)
1534[2019-05-15 13:27:03,064] INFO collation_server = latin1_swedish_ci (io.debezium.connector.mysql.SnapshotReader:827)
1535[2019-05-15 13:27:03,064] INFO enforce_gtid_consistency = ON (io.debezium.connector.mysql.SnapshotReader:827)
1536[2019-05-15 13:27:03,064] INFO gtid_executed_compression_period = 1000 (io.debezium.connector.mysql.SnapshotReader:827)
1537[2019-05-15 13:27:03,064] INFO gtid_mode = ON (io.debezium.connector.mysql.SnapshotReader:827)
1538[2019-05-15 13:27:03,064] INFO gtid_next = AUTOMATIC (io.debezium.connector.mysql.SnapshotReader:827)
1539[2019-05-15 13:27:03,065] INFO gtid_owned = (io.debezium.connector.mysql.SnapshotReader:827)
1540[2019-05-15 13:27:03,065] INFO gtid_purged = (io.debezium.connector.mysql.SnapshotReader:827)
1541[2019-05-15 13:27:03,065] INFO innodb_api_enable_binlog = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1542[2019-05-15 13:27:03,065] INFO innodb_locks_unsafe_for_binlog = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1543[2019-05-15 13:27:03,065] INFO innodb_version = 5.7.25 (io.debezium.connector.mysql.SnapshotReader:827)
1544[2019-05-15 13:27:03,065] INFO log_statements_unsafe_for_binlog = ON (io.debezium.connector.mysql.SnapshotReader:827)
1545[2019-05-15 13:27:03,065] INFO max_binlog_cache_size = 18446744073709547520 (io.debezium.connector.mysql.SnapshotReader:827)
1546[2019-05-15 13:27:03,065] INFO max_binlog_size = 1073741824 (io.debezium.connector.mysql.SnapshotReader:827)
1547[2019-05-15 13:27:03,065] INFO max_binlog_stmt_cache_size = 18446744073709547520 (io.debezium.connector.mysql.SnapshotReader:827)
1548[2019-05-15 13:27:03,065] INFO protocol_version = 10 (io.debezium.connector.mysql.SnapshotReader:827)
1549[2019-05-15 13:27:03,065] INFO session_track_gtids = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1550[2019-05-15 13:27:03,065] INFO slave_type_conversions = (io.debezium.connector.mysql.SnapshotReader:827)
1551[2019-05-15 13:27:03,065] INFO sync_binlog = 1 (io.debezium.connector.mysql.SnapshotReader:827)
1552[2019-05-15 13:27:03,065] INFO system_time_zone = IST (io.debezium.connector.mysql.SnapshotReader:827)
1553[2019-05-15 13:27:03,066] INFO time_zone = SYSTEM (io.debezium.connector.mysql.SnapshotReader:827)
1554[2019-05-15 13:27:03,066] INFO tls_version = TLSv1,TLSv1.1 (io.debezium.connector.mysql.SnapshotReader:827)
1555[2019-05-15 13:27:03,066] INFO tx_isolation = REPEATABLE-READ (io.debezium.connector.mysql.SnapshotReader:827)
1556[2019-05-15 13:27:03,066] INFO tx_read_only = OFF (io.debezium.connector.mysql.SnapshotReader:827)
1557[2019-05-15 13:27:03,066] INFO version = 5.7.25-log (io.debezium.connector.mysql.SnapshotReader:827)
1558[2019-05-15 13:27:03,066] INFO version_comment = MySQL Community Server (GPL) (io.debezium.connector.mysql.SnapshotReader:827)
1559[2019-05-15 13:27:03,066] INFO version_compile_machine = x86_64 (io.debezium.connector.mysql.SnapshotReader:827)
1560[2019-05-15 13:27:03,066] INFO version_compile_os = macos10.14 (io.debezium.connector.mysql.SnapshotReader:827)
1561[2019-05-15 13:27:03,066] INFO Step 0: disabling autocommit and enabling repeatable read transactions (io.debezium.connector.mysql.SnapshotReader:202)
1562[2019-05-15 13:27:03,069] INFO Step 1: flush and obtain global read lock to prevent writes to database (io.debezium.connector.mysql.SnapshotReader:226)
1563[2019-05-15 13:27:03,071] INFO Step 2: start transaction with consistent snapshot (io.debezium.connector.mysql.SnapshotReader:247)
1564[2019-05-15 13:27:03,072] INFO Step 3: read binlog position of MySQL master (io.debezium.connector.mysql.SnapshotReader:742)
1565[2019-05-15 13:27:03,075] INFO using binlog 'mysql-bin.000009' at position '1542' and gtid '0ead3b18-5461-11e9-be5a-846e9abad705:1-5' (io.debezium.connector.mysql.SnapshotReader:754)
1566[2019-05-15 13:27:03,076] INFO Step 4: read list of available databases (io.debezium.connector.mysql.SnapshotReader:272)
1567[2019-05-15 13:27:03,248] INFO list of available databases is: [information_schema, AadhaarDB, employees, mysql, performance_schema, sys] (io.debezium.connector.mysql.SnapshotReader:280)
1568[2019-05-15 13:27:03,248] INFO Step 5: read list of available tables in each database (io.debezium.connector.mysql.SnapshotReader:291)
1569[2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVDumpRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1570[2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVDumpRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1571[2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVIngestRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1572[2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVIngestRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1573[2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1574[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1575[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1576[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1577[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1578[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1579[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1580[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1581[2019-05-15 13:27:07,040] INFO 'AadhaarDB.AadhaarVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1582[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1583[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1584[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1585[2019-05-15 13:27:07,041] INFO 'AadhaarDB.Acct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1586[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctBalHist' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1587[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctPybl' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1588[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctPyblPmt' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1589[2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctRcvb' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1590[2019-05-15 13:27:07,042] INFO 'AadhaarDB.AcctRcvbPmt' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1591[2019-05-15 13:27:07,042] INFO 'AadhaarDB.Actv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1592[2019-05-15 13:27:07,042] INFO including 'AadhaarDB.AddressEntity' (io.debezium.connector.mysql.SnapshotReader:310)
1593[2019-05-15 13:27:07,043] INFO 'AadhaarDB.AddressEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1594[2019-05-15 13:27:07,043] INFO 'AadhaarDB.App' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1595[2019-05-15 13:27:07,043] INFO 'AadhaarDB.App_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1596[2019-05-15 13:27:07,043] INFO 'AadhaarDB.AppointmentLetterDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1597[2019-05-15 13:27:07,043] INFO 'AadhaarDB.AppointmentLetterDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1598[2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1599[2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1600[2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1601[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1602[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BankEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1603[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BankEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1604[2019-05-15 13:27:07,044] INFO 'AadhaarDB.Batch' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1605[2019-05-15 13:27:07,044] INFO 'AadhaarDB.Batch_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1606[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BirthCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1607[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BirthCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1608[2019-05-15 13:27:07,044] INFO 'AadhaarDB.BoardUniversityDatabase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1609[2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityEmail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1610[2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1611[2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityPhone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1612[2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVEvidenceEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1613[2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVEvidenceEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1614[2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1615[2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1616[2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1617[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1618[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1619[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1620[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1621[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1622[2019-05-15 13:27:07,046] INFO 'AadhaarDB.CharacterCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1623[2019-05-15 13:27:07,047] INFO 'AadhaarDB.CharacterCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1624[2019-05-15 13:27:07,047] INFO 'AadhaarDB.ClassOfVehicleCode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1625[2019-05-15 13:27:07,047] INFO 'AadhaarDB.Community' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1626[2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityAccessEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1627[2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityAccessEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1628[2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityActivityEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1629[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityConfiguration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1630[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityConfiguration_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1631[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityDeviceMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1632[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityDeviceMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1633[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1634[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1635[2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping_Batch' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1636[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualMapping_Batch_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1637[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualNote' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1638[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualNote_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1639[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualReview' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1640[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualReview_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1641[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityInviteEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1642[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityInviteEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1643[2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityOffering' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1644[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOfferingMode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1645[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOfferingMode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1646[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOffering_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1647[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityServices' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1648[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityServices_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1649[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityTag' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1650[2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityTag_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1651[2019-05-15 13:27:07,050] INFO 'AadhaarDB.Community_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1652[2019-05-15 13:27:07,050] INFO 'AadhaarDB.ConsentResponseEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1653[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CovDetailEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1654[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CovDetailEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1655[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalAct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1656[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalAct_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1657[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1658[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordPetitionerName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1659[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordPetitionerName_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1660[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordRespondentName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1661[2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordRespondentName_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1662[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1663[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_CriminalAct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1664[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_CriminalAct_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1665[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1666[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1667[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomSchemaEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1668[2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomSchemaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1669[2019-05-15 13:27:07,052] INFO 'AadhaarDB.DBReportEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1670[2019-05-15 13:27:07,052] INFO 'AadhaarDB.DBReportEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1671[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportEntity_ParametersEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1672[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportEntity_ParametersEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1673[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportParametersEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1674[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportParametersEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1675[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1676[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1677[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1678[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1679[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCSMissingField' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1680[2019-05-15 13:27:07,053] INFO 'AadhaarDB.DLVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1681[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1682[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVReport_CovDetailEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1683[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1684[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1685[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DataCollectionSchemaEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1686[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DataCollectionSchemaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1687[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DefaultDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1688[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DefaultDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1689[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DocumentEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1690[2019-05-15 13:27:07,054] INFO 'AadhaarDB.DocumentEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1691[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationReportEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1692[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationReportEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1693[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1694[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1695[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DriverLicenceCategory' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1696[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DriverLicenceCategory_VehicleClass' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1697[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DrivingLicenceDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1698[2019-05-15 13:27:07,055] INFO 'AadhaarDB.DrivingLicenceDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1699[2019-05-15 13:27:07,055] INFO 'AadhaarDB.EDUVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1700[2019-05-15 13:27:07,055] INFO 'AadhaarDB.EDUVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1701[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1702[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1703[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1704[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1705[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1706[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1707[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1708[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1709[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1710[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1711[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EdVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1712[2019-05-15 13:27:07,056] INFO 'AadhaarDB.EdVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1713[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationDetailDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1714[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationDetailDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1715[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1716[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1717[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1718[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1719[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmpVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1720[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmpVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1721[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerDatabase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1722[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerEmail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1723[2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1724[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmployerPhone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1725[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1726[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentRecord_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1727[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1728[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1729[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1730[2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1731[2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExotelTelecomDetails' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1732[2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExotelTelecomDetails_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1733[2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExperienceLetter' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1734[2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExperienceLetter_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1735[2019-05-15 13:27:07,058] INFO 'AadhaarDB.FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1736[2019-05-15 13:27:07,059] INFO 'AadhaarDB.FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1737[2019-05-15 13:27:07,059] INFO 'AadhaarDB.FinanceInformationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1738[2019-05-15 13:27:07,059] INFO 'AadhaarDB.FinanceInformationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1739[2019-05-15 13:27:07,059] INFO 'AadhaarDB.GasConnectionDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1740[2019-05-15 13:27:07,059] INFO 'AadhaarDB.GasConnectionDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1741[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IVRMessage' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1742[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IVRMessage_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1743[2019-05-15 13:27:07,059] INFO 'AadhaarDB.Individual' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1744[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualAadhaarData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1745[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualAadhaarData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1746[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualBiometricVerification' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1747[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualBiometricVerification_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1748[2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualCommunityTagValue' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1749[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualCommunityTagValue_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1750[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualConsent' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1751[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualConsentAudit' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1752[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualRegistrationInvite' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1753[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualRegistrationInvite_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1754[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerification' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1755[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerificationCode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1756[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerificationCode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1757[2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerification_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1758[2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1759[2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_Profession' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1760[2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_Profession_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1761[2019-05-15 13:27:07,061] INFO 'AadhaarDB.InstaveritasVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1762[2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyOfferingMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1763[2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyOfferingMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1764[2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyReason' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1765[2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyReason_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1766[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVImageMigrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1767[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVMockLocationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1768[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVMockLocationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1769[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1770[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1771[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_ReferenceFileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1772[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_ReferenceFileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1773[2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1774[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1775[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1776[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1777[2019-05-15 13:27:07,062] INFO including 'AadhaarDB.LAVerificationRequest' (io.debezium.connector.mysql.SnapshotReader:310)
1778[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1779[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorization' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1780[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorizationResponseEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1781[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorization_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1782[2019-05-15 13:27:07,062] INFO 'AadhaarDB.LicenceVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1783[2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1784[2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationEntity_LicenceVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1785[2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1786[2019-05-15 13:27:07,063] INFO 'AadhaarDB.LogTable' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1787[2019-05-15 13:27:07,063] INFO 'AadhaarDB.NonAadhaarData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1788[2019-05-15 13:27:07,063] INFO 'AadhaarDB.NonAadhaarData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1789[2019-05-15 13:27:07,063] INFO 'AadhaarDB.Offering' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1790[2019-05-15 13:27:07,063] INFO 'AadhaarDB.OfferingMode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1791[2019-05-15 13:27:07,063] INFO 'AadhaarDB.OfferingMode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1792[2019-05-15 13:27:07,063] INFO 'AadhaarDB.Offering_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1793[2019-05-15 13:27:07,063] INFO 'AadhaarDB.OnGridService' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1794[2019-05-15 13:27:07,063] INFO 'AadhaarDB.OnGridService_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1795[2019-05-15 13:27:07,063] INFO 'AadhaarDB.PANCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1796[2019-05-15 13:27:07,063] INFO 'AadhaarDB.PANCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1797[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1798[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1799[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1800[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1801[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1802[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1803[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1804[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1805[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1806[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1807[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1808[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1809[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1810[2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1811[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1812[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1813[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1814[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1815[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1816[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1817[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1818[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1819[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1820[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1821[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1822[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1823[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1824[2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1825[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1826[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1827[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1828[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1829[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1830[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1831[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PassportDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1832[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PassportDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1833[2019-05-15 13:27:07,066] INFO including 'AadhaarDB.Personnel' (io.debezium.connector.mysql.SnapshotReader:310)
1834[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelDeviceRegistrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1835[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelDeviceRegistrationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1836[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelRuleViolationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1837[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelRuleViolationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1838[2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelServiceAreaDetails' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1839[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PersonnelServiceAreaDetails_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1840[2019-05-15 13:27:07,067] INFO including 'AadhaarDB.PersonnelServiceAreaEntity' (io.debezium.connector.mysql.SnapshotReader:310)
1841[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PersonnelServiceAreaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1842[2019-05-15 13:27:07,067] INFO 'AadhaarDB.Personnel_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1843[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PhoneConversation' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1844[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PhoneConversation_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1845[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PincodeLocationMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1846[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PincodeLocationMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1847[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PoliceVerificationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1848[2019-05-15 13:27:07,067] INFO 'AadhaarDB.PoliceVerificationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1849[2019-05-15 13:27:07,067] INFO 'AadhaarDB.ProcedureTaskEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1850[2019-05-15 13:27:07,068] INFO 'AadhaarDB.ProcedureTaskEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1851[2019-05-15 13:27:07,068] INFO 'AadhaarDB.Profession' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1852[2019-05-15 13:27:07,068] INFO 'AadhaarDB.Profession_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1853[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1854[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1855[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1856[2019-05-15 13:27:07,068] INFO 'AadhaarDB.REVCHANGES' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1857[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RationCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1858[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RationCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1859[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RecommendationLetter' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1860[2019-05-15 13:27:07,068] INFO 'AadhaarDB.RecommendationLetter_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1861[2019-05-15 13:27:07,068] INFO 'AadhaarDB.ReferenceProvider' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1862[2019-05-15 13:27:07,069] INFO 'AadhaarDB.ReferenceProvider_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1863[2019-05-15 13:27:07,069] INFO 'AadhaarDB.RegisteredDeviceEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1864[2019-05-15 13:27:07,069] INFO 'AadhaarDB.RegisteredDeviceEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1865[2019-05-15 13:27:07,069] INFO 'AadhaarDB.RentAgreementDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1866[2019-05-15 13:27:07,069] INFO 'AadhaarDB.RentAgreementDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1867[2019-05-15 13:27:07,069] INFO 'AadhaarDB.ResourceAccessRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1868[2019-05-15 13:27:07,069] INFO 'AadhaarDB.ResourceAccessRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1869[2019-05-15 13:27:07,069] INFO 'AadhaarDB.RevisionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1870[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SalarySlipDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1871[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SalarySlipDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1872[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegActionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1873[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegActionEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1874[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegLifeCycleEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1875[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegLifeCycleEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1876[2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegistrationAction' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1877[2019-05-15 13:27:07,070] INFO 'AadhaarDB.SelfRegistrationAction_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1878[2019-05-15 13:27:07,070] INFO 'AadhaarDB.SkillCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1879[2019-05-15 13:27:07,070] INFO 'AadhaarDB.SkillCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1880[2019-05-15 13:27:07,070] INFO 'AadhaarDB.TextMessage' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1881[2019-05-15 13:27:07,070] INFO 'AadhaarDB.TransactionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1882[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserBookmarkEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1883[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserBookmarkEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1884[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1885[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1886[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserFeedbackEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1887[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserFeedbackEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1888[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserRegistrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1889[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserRegistrationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1890[2019-05-15 13:27:07,070] INFO 'AadhaarDB.UtilityBillEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1891[2019-05-15 13:27:07,071] INFO 'AadhaarDB.UtilityBillEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1892[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1893[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1894[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1895[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1896[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleClass' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1897[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleRegistrationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1898[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleRegistrationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1899[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1900[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1901[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1902[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1903[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionRule' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1904[2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionRule_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1905[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationCompletionEmailDetail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1906[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationCompletionEmailLog' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1907[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationInsufficiency' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1908[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationInsufficiency_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1909[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationLabel' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1910[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationLabel_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1911[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationReportBase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1912[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationReportBase_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1913[2019-05-15 13:27:07,072] INFO including 'AadhaarDB.VerificationRequestBase' (io.debezium.connector.mysql.SnapshotReader:310)
1914[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestBase_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1915[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestInsufficiencies' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1916[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestInsufficiencies_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1917[2019-05-15 13:27:07,072] INFO 'AadhaarDB.VoterCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1918[2019-05-15 13:27:07,073] INFO 'AadhaarDB.VoterCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1919[2019-05-15 13:27:07,073] INFO 'AadhaarDB.acctNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1920[2019-05-15 13:27:07,073] INFO 'AadhaarDB.actvNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1921[2019-05-15 13:27:07,073] INFO 'AadhaarDB.address_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1922[2019-05-15 13:27:07,073] INFO 'AadhaarDB.avdump_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1923[2019-05-15 13:27:07,073] INFO 'AadhaarDB.avingest_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1924[2019-05-15 13:27:07,073] INFO 'AadhaarDB.batch_id_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1925[2019-05-15 13:27:07,073] INFO 'AadhaarDB.bookmarkId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1926[2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvevidence_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1927[2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvreport_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1928[2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvrequest_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1929[2019-05-15 13:27:07,073] INFO 'AadhaarDB.commtag_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1930[2019-05-15 13:27:07,073] INFO 'AadhaarDB.community_access_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1931[2019-05-15 13:27:07,073] INFO 'AadhaarDB.community_activity_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1932[2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_individual_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1933[2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_note_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1934[2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1935[2019-05-15 13:27:07,074] INFO 'AadhaarDB.communityservicesId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1936[2019-05-15 13:27:07,074] INFO 'AadhaarDB.customdata_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1937[2019-05-15 13:27:07,074] INFO 'AadhaarDB.datacollection_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1938[2019-05-15 13:27:07,074] INFO 'AadhaarDB.dbreportentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1939[2019-05-15 13:27:07,074] INFO 'AadhaarDB.dbreportparametersentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1940[2019-05-15 13:27:07,074] INFO 'AadhaarDB.dcmissingfield_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1941[2019-05-15 13:27:07,074] INFO 'AadhaarDB.document_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1942[2019-05-15 13:27:07,074] INFO 'AadhaarDB.documentverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1943[2019-05-15 13:27:07,074] INFO 'AadhaarDB.documentverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1944[2019-05-15 13:27:07,074] INFO 'AadhaarDB.driverLicenceCategoryId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1945[2019-05-15 13:27:07,074] INFO 'AadhaarDB.educationform_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1946[2019-05-15 13:27:07,074] INFO 'AadhaarDB.educationverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1947[2019-05-15 13:27:07,075] INFO 'AadhaarDB.educationverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1948[2019-05-15 13:27:07,075] INFO 'AadhaarDB.employment_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1949[2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentform_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1950[2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1951[2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1952[2019-05-15 13:27:07,075] INFO 'AadhaarDB.hibernate_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1953[2019-05-15 13:27:07,075] INFO 'AadhaarDB.incident_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1954[2019-05-15 13:27:07,075] INFO 'AadhaarDB.individualId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1955[2019-05-15 13:27:07,075] INFO 'AadhaarDB.indiviudalconsentaudit_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1956[2019-05-15 13:27:07,075] INFO 'AadhaarDB.insufficiency_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1957[2019-05-15 13:27:07,075] INFO 'AadhaarDB.laverification_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1958[2019-05-15 13:27:07,075] INFO 'AadhaarDB.lavmock_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1959[2019-05-15 13:27:07,075] INFO 'AadhaarDB.lavrequest_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1960[2019-05-15 13:27:07,075] INFO 'AadhaarDB.licenceVerificationId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1961[2019-05-15 13:27:07,075] INFO 'AadhaarDB.licenceVerificationRecordId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1962[2019-05-15 13:27:07,076] INFO 'AadhaarDB.nonaadhaarindividualId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1963[2019-05-15 13:27:07,076] INFO 'AadhaarDB.offeringId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1964[2019-05-15 13:27:07,076] INFO 'AadhaarDB.ongridservicesId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1965[2019-05-15 13:27:07,076] INFO 'AadhaarDB.pccrequestentity_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1966[2019-05-15 13:27:07,076] INFO 'AadhaarDB.pccverificationreport_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1967[2019-05-15 13:27:07,076] INFO 'AadhaarDB.personnelservicearea_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1968[2019-05-15 13:27:07,076] INFO 'AadhaarDB.phoneconversation_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1969[2019-05-15 13:27:07,076] INFO 'AadhaarDB.pincodelocation_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1970[2019-05-15 13:27:07,076] INFO 'AadhaarDB.procedureinitiatorentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1971[2019-05-15 13:27:07,076] INFO 'AadhaarDB.pvlawfirmrequestentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1972[2019-05-15 13:27:07,076] INFO 'AadhaarDB.pvlawfirmverificationreport_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1973[2019-05-15 13:27:07,076] INFO 'AadhaarDB.refprovider_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1974[2019-05-15 13:27:07,076] INFO 'AadhaarDB.registration_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1975[2019-05-15 13:27:07,076] INFO 'AadhaarDB.reviewAccess_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1976[2019-05-15 13:27:07,076] INFO 'AadhaarDB.selfregaction_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1977[2019-05-15 13:27:07,077] INFO 'AadhaarDB.selfreglifecycle_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1978[2019-05-15 13:27:07,077] INFO 'AadhaarDB.telecomdetails_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1979[2019-05-15 13:27:07,077] INFO 'AadhaarDB.transactionNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1980[2019-05-15 13:27:07,077] INFO 'AadhaarDB.uidverrep_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1981[2019-05-15 13:27:07,077] INFO 'AadhaarDB.uidverreq_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1982[2019-05-15 13:27:07,077] INFO 'AadhaarDB.user_feedback_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1983[2019-05-15 13:27:07,077] INFO 'AadhaarDB.user_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1984[2019-05-15 13:27:07,077] INFO 'AadhaarDB.vehicleClassId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1985[2019-05-15 13:27:07,077] INFO 'AadhaarDB.verification_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1986[2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationinsufficiency_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1987[2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationlabel_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1988[2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationlog_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1989[2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationrule_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1990[2019-05-15 13:27:07,077] INFO 'AadhaarDB.violationentity_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1991[2019-05-15 13:27:07,241] INFO 'employees.departments' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1992[2019-05-15 13:27:07,241] INFO 'employees.dept_emp' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1993[2019-05-15 13:27:07,241] INFO 'employees.dept_manager' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1994[2019-05-15 13:27:07,242] INFO 'employees.employees' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1995[2019-05-15 13:27:07,242] INFO 'employees.employees_copy' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1996[2019-05-15 13:27:07,242] INFO 'employees.salaries' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1997[2019-05-15 13:27:07,242] INFO 'employees.titles' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1998[2019-05-15 13:27:07,494] INFO 'mysql.columns_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
1999[2019-05-15 13:27:07,494] INFO 'mysql.db' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2000[2019-05-15 13:27:07,494] INFO 'mysql.engine_cost' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2001[2019-05-15 13:27:07,495] INFO 'mysql.event' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2002[2019-05-15 13:27:07,495] INFO 'mysql.func' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2003[2019-05-15 13:27:07,495] INFO 'mysql.general_log' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2004[2019-05-15 13:27:07,495] INFO 'mysql.gtid_executed' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2005[2019-05-15 13:27:07,495] INFO 'mysql.help_category' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2006[2019-05-15 13:27:07,495] INFO 'mysql.help_keyword' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2007[2019-05-15 13:27:07,495] INFO 'mysql.help_relation' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2008[2019-05-15 13:27:07,495] INFO 'mysql.help_topic' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2009[2019-05-15 13:27:07,495] INFO 'mysql.innodb_index_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2010[2019-05-15 13:27:07,495] INFO 'mysql.innodb_table_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2011[2019-05-15 13:27:07,495] INFO 'mysql.ndb_binlog_index' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2012[2019-05-15 13:27:07,496] INFO 'mysql.plugin' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2013[2019-05-15 13:27:07,496] INFO 'mysql.proc' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2014[2019-05-15 13:27:07,496] INFO 'mysql.procs_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2015[2019-05-15 13:27:07,496] INFO 'mysql.proxies_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2016[2019-05-15 13:27:07,496] INFO 'mysql.server_cost' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2017[2019-05-15 13:27:07,496] INFO 'mysql.servers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2018[2019-05-15 13:27:07,496] INFO 'mysql.slave_master_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2019[2019-05-15 13:27:07,496] INFO 'mysql.slave_relay_log_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2020[2019-05-15 13:27:07,496] INFO 'mysql.slave_worker_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2021[2019-05-15 13:27:07,496] INFO 'mysql.slow_log' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2022[2019-05-15 13:27:07,496] INFO 'mysql.tables_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2023[2019-05-15 13:27:07,496] INFO 'mysql.time_zone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2024[2019-05-15 13:27:07,497] INFO 'mysql.time_zone_leap_second' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2025[2019-05-15 13:27:07,497] INFO 'mysql.time_zone_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2026[2019-05-15 13:27:07,497] INFO 'mysql.time_zone_transition' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2027[2019-05-15 13:27:07,497] INFO 'mysql.time_zone_transition_type' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2028[2019-05-15 13:27:07,497] INFO 'mysql.user' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2029[2019-05-15 13:27:07,688] INFO 'performance_schema.accounts' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2030[2019-05-15 13:27:07,688] INFO 'performance_schema.cond_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2031[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2032[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2033[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2034[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_summary_by_account_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2035[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_summary_by_host_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2036[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_summary_by_thread_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2037[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_summary_by_user_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2038[2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_summary_global_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2039[2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2040[2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2041[2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2042[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_account_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2043[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_digest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2044[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_host_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2045[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_program' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2046[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_thread_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2047[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_by_user_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2048[2019-05-15 13:27:07,690] INFO 'performance_schema.events_statements_summary_global_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2049[2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2050[2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2051[2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2052[2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_summary_by_account_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2053[2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_summary_by_host_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2054[2019-05-15 13:27:07,691] INFO 'performance_schema.events_transactions_summary_by_thread_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2055[2019-05-15 13:27:07,691] INFO 'performance_schema.events_transactions_summary_by_user_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2056[2019-05-15 13:27:07,691] INFO 'performance_schema.events_transactions_summary_global_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2057[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2058[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2059[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2060[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_by_account_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2061[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_by_host_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2062[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_by_instance' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2063[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_by_thread_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2064[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_by_user_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2065[2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_summary_global_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2066[2019-05-15 13:27:07,692] INFO 'performance_schema.file_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2067[2019-05-15 13:27:07,692] INFO 'performance_schema.file_summary_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2068[2019-05-15 13:27:07,692] INFO 'performance_schema.file_summary_by_instance' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2069[2019-05-15 13:27:07,692] INFO 'performance_schema.global_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2070[2019-05-15 13:27:07,692] INFO 'performance_schema.global_variables' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2071[2019-05-15 13:27:07,692] INFO 'performance_schema.host_cache' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2072[2019-05-15 13:27:07,692] INFO 'performance_schema.hosts' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2073[2019-05-15 13:27:07,692] INFO 'performance_schema.memory_summary_by_account_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2074[2019-05-15 13:27:07,692] INFO 'performance_schema.memory_summary_by_host_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2075[2019-05-15 13:27:07,692] INFO 'performance_schema.memory_summary_by_thread_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2076[2019-05-15 13:27:07,692] INFO 'performance_schema.memory_summary_by_user_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2077[2019-05-15 13:27:07,692] INFO 'performance_schema.memory_summary_global_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2078[2019-05-15 13:27:07,693] INFO 'performance_schema.metadata_locks' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2079[2019-05-15 13:27:07,693] INFO 'performance_schema.mutex_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2080[2019-05-15 13:27:07,693] INFO 'performance_schema.objects_summary_global_by_type' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2081[2019-05-15 13:27:07,693] INFO 'performance_schema.performance_timers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2082[2019-05-15 13:27:07,693] INFO 'performance_schema.prepared_statements_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2083[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_configuration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2084[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2085[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_status_by_coordinator' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2086[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_status_by_worker' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2087[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_connection_configuration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2088[2019-05-15 13:27:07,693] INFO 'performance_schema.replication_connection_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2089[2019-05-15 13:27:07,694] INFO 'performance_schema.replication_group_member_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2090[2019-05-15 13:27:07,694] INFO 'performance_schema.replication_group_members' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2091[2019-05-15 13:27:07,694] INFO 'performance_schema.rwlock_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2092[2019-05-15 13:27:07,694] INFO 'performance_schema.session_account_connect_attrs' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2093[2019-05-15 13:27:07,694] INFO 'performance_schema.session_connect_attrs' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2094[2019-05-15 13:27:07,694] INFO 'performance_schema.session_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2095[2019-05-15 13:27:07,694] INFO 'performance_schema.session_variables' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2096[2019-05-15 13:27:07,694] INFO 'performance_schema.setup_actors' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2097[2019-05-15 13:27:07,694] INFO 'performance_schema.setup_consumers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2098[2019-05-15 13:27:07,694] INFO 'performance_schema.setup_instruments' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2099[2019-05-15 13:27:07,694] INFO 'performance_schema.setup_objects' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2100[2019-05-15 13:27:07,695] INFO 'performance_schema.setup_timers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2101[2019-05-15 13:27:07,695] INFO 'performance_schema.socket_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2102[2019-05-15 13:27:07,695] INFO 'performance_schema.socket_summary_by_event_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2103[2019-05-15 13:27:07,695] INFO 'performance_schema.socket_summary_by_instance' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2104[2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_account' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2105[2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_host' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2106[2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2107[2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_user' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2108[2019-05-15 13:27:07,695] INFO 'performance_schema.table_handles' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2109[2019-05-15 13:27:07,695] INFO 'performance_schema.table_io_waits_summary_by_index_usage' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2110[2019-05-15 13:27:07,695] INFO 'performance_schema.table_io_waits_summary_by_table' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2111[2019-05-15 13:27:07,695] INFO 'performance_schema.table_lock_waits_summary_by_table' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2112[2019-05-15 13:27:07,696] INFO 'performance_schema.threads' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2113[2019-05-15 13:27:07,696] INFO 'performance_schema.user_variables_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2114[2019-05-15 13:27:07,696] INFO 'performance_schema.users' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2115[2019-05-15 13:27:07,696] INFO 'performance_schema.variables_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2116[2019-05-15 13:27:08,073] INFO 'sys.sys_config' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
2117[2019-05-15 13:27:08,077] INFO snapshot continuing with database(s): [AadhaarDB] (io.debezium.connector.mysql.SnapshotReader:338)
2118[2019-05-15 13:27:08,077] INFO Step 6: generating DROP and CREATE statements to reflect current database schemas: (io.debezium.connector.mysql.SnapshotReader:383)
2119[2019-05-15 13:27:08,871] INFO SET character_set_server=latin1, collation_server=latin1_swedish_ci; (io.debezium.connector.mysql.SnapshotReader:886)
2120[2019-05-15 13:27:08,922] INFO DROP TABLE IF EXISTS `AadhaarDB`.`VerificationRequestBase` (io.debezium.connector.mysql.SnapshotReader:886)
2121[2019-05-15 13:27:08,927] INFO DROP TABLE IF EXISTS `AadhaarDB`.`LAVerificationRequest` (io.debezium.connector.mysql.SnapshotReader:886)
2122[2019-05-15 13:27:08,932] INFO DROP TABLE IF EXISTS `AadhaarDB`.`AddressEntity` (io.debezium.connector.mysql.SnapshotReader:886)
2123[2019-05-15 13:27:08,936] INFO DROP TABLE IF EXISTS `AadhaarDB`.`Personnel` (io.debezium.connector.mysql.SnapshotReader:886)
2124[2019-05-15 13:27:08,940] INFO DROP TABLE IF EXISTS `AadhaarDB`.`PersonnelServiceAreaEntity` (io.debezium.connector.mysql.SnapshotReader:886)
2125[2019-05-15 13:27:08,950] INFO DROP DATABASE IF EXISTS `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
2126[2019-05-15 13:27:08,959] INFO CREATE DATABASE `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
2127[2019-05-15 13:27:08,967] INFO USE `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
2128[2019-05-15 13:27:09,042] WARN [Producer clientId=producer-4] Error while fetching metadata with correlation id 3 : {cdc-lav=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1023)
2129[2019-05-15 13:27:09,095] INFO CREATE TABLE `AddressEntity` (
2130 `id` bigint(20) NOT NULL AUTO_INCREMENT,
2131 `created` datetime NOT NULL,
2132 `updated` datetime NOT NULL,
2133 `co` varchar(255) DEFAULT NULL,
2134 `district` varchar(255) DEFAULT NULL,
2135 `entityId` varchar(255) NOT NULL,
2136 `entityType` varchar(255) NOT NULL,
2137 `landmark` varchar(255) DEFAULT NULL,
2138 `latitude` double DEFAULT NULL,
2139 `longitude` double DEFAULT NULL,
2140 `line1` varchar(255) DEFAULT NULL,
2141 `line2` varchar(255) DEFAULT NULL,
2142 `locality` varchar(255) DEFAULT NULL,
2143 `pincode` varchar(255) DEFAULT NULL,
2144 `state` varchar(255) DEFAULT NULL,
2145 `vtc` varchar(255) DEFAULT NULL,
2146 `vendor` varchar(255) DEFAULT NULL,
2147 `verificationRequestId` bigint(20) DEFAULT NULL,
2148 `verificationRequestStatus` varchar(255) DEFAULT NULL,
2149 `verificationStatus` varchar(255) DEFAULT NULL,
2150 `fullAddress` varchar(255) DEFAULT NULL,
2151 `referredDocuments` varchar(255) DEFAULT NULL,
2152 `manuallyUpdated` bit(1) NOT NULL,
2153 `lFullAddress` varchar(255) DEFAULT NULL,
2154 `lnCode` varchar(255) DEFAULT NULL,
2155 `locationPoint` geometry DEFAULT NULL,
2156 `locationType` varchar(255) DEFAULT NULL,
2157 `addressType` varchar(255) DEFAULT NULL,
2158 PRIMARY KEY (`id`),
2159 KEY `is_entityType` (`id`,`entityType`),
2160 KEY `id_entityId__entityType` (`id`,`entityId`,`entityType`)
2161) ENGINE=InnoDB AUTO_INCREMENT=87091 DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
2162[2019-05-15 13:27:09,105] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.AddressEntity.Value' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.AddressEntity.Value' (io.debezium.connector.mysql.MySqlSchema:170)
2163[2019-05-15 13:27:09,106] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.AddressEntity.Key' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.AddressEntity.Key' (io.debezium.connector.mysql.MySqlSchema:170)
2164[2019-05-15 13:27:09,136] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.AddressEntity.Envelope' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.AddressEntity.Envelope' (io.debezium.connector.mysql.MySqlSchema:170)
2165[2019-05-15 13:27:09,230] INFO CREATE TABLE `LAVerificationRequest` (
2166 `note` varchar(255) DEFAULT NULL,
2167 `verificationResult` varchar(255) DEFAULT NULL,
2168 `id` bigint(20) NOT NULL,
2169 `address_id` bigint(20) NOT NULL,
2170 PRIMARY KEY (`id`),
2171 KEY `FKncuu1mr7ca7ay5pox50rajjyl` (`address_id`),
2172 CONSTRAINT `FK91oesj28nsxuwd1ckt2qmmo49` FOREIGN KEY (`id`) REFERENCES `VerificationRequestBase` (`id`),
2173 CONSTRAINT `FKncuu1mr7ca7ay5pox50rajjyl` FOREIGN KEY (`address_id`) REFERENCES `AddressEntity` (`id`)
2174) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
2175[2019-05-15 13:27:09,242] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.LAVerificationRequest.Value' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.LAVerificationRequest.Value' (io.debezium.connector.mysql.MySqlSchema:170)
2176[2019-05-15 13:27:09,242] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.LAVerificationRequest.Key' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.LAVerificationRequest.Key' (io.debezium.connector.mysql.MySqlSchema:170)
2177[2019-05-15 13:27:09,242] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.LAVerificationRequest.Envelope' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.LAVerificationRequest.Envelope' (io.debezium.connector.mysql.MySqlSchema:170)
2178[2019-05-15 13:27:09,295] WARN Column is missing a character set: source CHAR(20) NOT NULL DEFAULT VALUE Odin (io.debezium.connector.mysql.MySqlValueConverters:304)
2179[2019-05-15 13:27:09,295] WARN Using UTF-8 charset by default for column without charset: source CHAR(20) NOT NULL DEFAULT VALUE Odin (io.debezium.connector.mysql.MySqlValueConverters:279)
2180[2019-05-15 13:27:09,328] INFO CREATE TABLE `Personnel` (
2181 `id` bigint(20) NOT NULL AUTO_INCREMENT,
2182 `aadhaarNumber` varchar(255) DEFAULT NULL,
2183 `accessToken` varchar(255) NOT NULL,
2184 `email` varchar(255) NOT NULL,
2185 `gender` varchar(255) NOT NULL,
2186 `isActive` bit(1) NOT NULL,
2187 `name` varchar(255) NOT NULL,
2188 `phone` varchar(255) NOT NULL,
2189 `type` varchar(255) NOT NULL,
2190 `city` varchar(255) NOT NULL,
2191 `supervisor_id` bigint(20) DEFAULT NULL,
2192 `Personnel_id` bigint(20) DEFAULT NULL,
2193 `bankAccountHolderName` varchar(255) DEFAULT NULL,
2194 `bankAccountIFSCCode` varchar(255) DEFAULT NULL,
2195 `bankAccountNumber` varchar(255) DEFAULT NULL,
2196 `bankName` varchar(255) DEFAULT NULL,
2197 `profileImageUrl` varchar(255) DEFAULT NULL,
2198 `upiAddress` varchar(255) DEFAULT NULL,
2199 `unitVerificationPrice` int(11) NOT NULL,
2200 `gpsStatus` bit(1) NOT NULL,
2201 `appVersion` int(11) NOT NULL,
2202 `created` datetime DEFAULT NULL,
2203 `updated` datetime DEFAULT NULL,
2204 `bankAccountBranchName` varchar(255) DEFAULT NULL,
2205 `payToSupervisor` tinyint(1) DEFAULT '0',
2206 `consentText` longtext NOT NULL,
2207 `source` char(20) NOT NULL DEFAULT 'Odin',
2208 `individual_id` bigint(20) DEFAULT NULL,
2209 `lastSeen` datetime DEFAULT NULL,
2210 `groupNotificationKey` varchar(255) DEFAULT NULL,
2211 `personnelGCMID` longtext,
2212 `documentId` varchar(255) DEFAULT NULL,
2213 `documentURL` varchar(255) DEFAULT NULL,
2214 `documentType` varchar(255) DEFAULT NULL,
2215 `inactiveReason` varchar(255) DEFAULT NULL,
2216 `individualId` bigint(20) DEFAULT NULL,
2217 `alternatePhone` varchar(255) DEFAULT NULL,
2218 `telecomCircle` varchar(255) DEFAULT NULL,
2219 PRIMARY KEY (`id`),
2220 UNIQUE KEY `UK_rt8lmrna0tfd1j1rde43w3idl` (`accessToken`),
2221 UNIQUE KEY `UK_lx6un5vnx6694ljd4qyxpwqlf` (`email`),
2222 UNIQUE KEY `UK_1wjgkg0ywos5vwyfmt9nqkevh` (`phone`),
2223 UNIQUE KEY `UK_g6b5ofiqra1wif1rcwqv3l3bb` (`alternatePhone`),
2224 KEY `FKndogdsmk4bpywt3i1ysb481si` (`supervisor_id`),
2225 CONSTRAINT `FKndogdsmk4bpywt3i1ysb481si` FOREIGN KEY (`supervisor_id`) REFERENCES `Personnel` (`id`),
2226 CONSTRAINT `FKnet2cwtxnkqfk16dx0dsi8ci1` FOREIGN KEY (`supervisor_id`) REFERENCES `Personnel` (`id`)
2227) ENGINE=InnoDB AUTO_INCREMENT=249 DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
2228[2019-05-15 13:27:09,333] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.Personnel.Value' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.Personnel.Value' (io.debezium.connector.mysql.MySqlSchema:170)
2229[2019-05-15 13:27:09,333] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.Personnel.Key' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.Personnel.Key' (io.debezium.connector.mysql.MySqlSchema:170)
2230[2019-05-15 13:27:09,334] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.Personnel.Envelope' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.Personnel.Envelope' (io.debezium.connector.mysql.MySqlSchema:170)
2231[2019-05-15 13:27:09,364] INFO CREATE TABLE `PersonnelServiceAreaEntity` (
2232 `id` bigint(20) NOT NULL,
2233 `created` datetime DEFAULT NULL,
2234 `updated` datetime DEFAULT NULL,
2235 `deleted` bit(1) NOT NULL,
2236 `personnel_id` bigint(20) DEFAULT NULL,
2237 `pincode` varchar(255) NOT NULL,
2238 `point` geometry NOT NULL,
2239 PRIMARY KEY (`id`),
2240 KEY `FKgxfx9qwhpreeth3i7p92k5ldk` (`personnel_id`),
2241 CONSTRAINT `FKgxfx9qwhpreeth3i7p92k5ldk` FOREIGN KEY (`personnel_id`) REFERENCES `Personnel` (`id`)
2242) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
2243[2019-05-15 13:27:09,368] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.PersonnelServiceAreaEntity.Value' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.PersonnelServiceAreaEntity.Value' (io.debezium.connector.mysql.MySqlSchema:170)
2244[2019-05-15 13:27:09,368] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.PersonnelServiceAreaEntity.Key' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.PersonnelServiceAreaEntity.Key' (io.debezium.connector.mysql.MySqlSchema:170)
2245[2019-05-15 13:27:09,368] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.PersonnelServiceAreaEntity.Envelope' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.PersonnelServiceAreaEntity.Envelope' (io.debezium.connector.mysql.MySqlSchema:170)
2246[2019-05-15 13:27:09,401] INFO CREATE TABLE `VerificationRequestBase` (
2247 `id` bigint(20) NOT NULL,
2248 `created` datetime DEFAULT NULL,
2249 `updated` datetime DEFAULT NULL,
2250 `deleted` bit(1) NOT NULL,
2251 `closedDate` datetime DEFAULT NULL,
2252 `closedReason` int(11) DEFAULT NULL,
2253 `closedRemarks` varchar(255) DEFAULT NULL,
2254 `completedDate` datetime DEFAULT NULL,
2255 `dataSufficiencyDate` datetime DEFAULT NULL,
2256 `initiationDate` datetime DEFAULT NULL,
2257 `lastActionDate` datetime DEFAULT NULL,
2258 `offeringCode` varchar(50) NOT NULL,
2259 `onHoldHours` bigint(20) DEFAULT NULL,
2260 `onHoldSince` datetime DEFAULT NULL,
2261 `state` varchar(255) DEFAULT NULL,
2262 `assignedTo_id` bigint(20) DEFAULT NULL,
2263 `individual_id` bigint(20) DEFAULT NULL,
2264 `parentCommunity_id` bigint(20) DEFAULT NULL,
2265 `report_id` bigint(20) DEFAULT NULL,
2266 `requestedBy_id` bigint(20) DEFAULT NULL,
2267 `requestingCommunity_id` bigint(20) DEFAULT NULL,
2268 `submittedDate` datetime DEFAULT NULL,
2269 `verificationLabels` longtext,
2270 `offeringMode` varchar(50) DEFAULT NULL,
2271 PRIMARY KEY (`id`),
2272 KEY `FKsq3rb61vbid8ianb65trwpw33` (`assignedTo_id`),
2273 KEY `FKex0gu3dk0loy27kjk1yff261v` (`individual_id`),
2274 KEY `FKt2pm09wy1e7x0ar209iaxl5ov` (`parentCommunity_id`),
2275 KEY `FKsovu3q3gleeuypsabo0uftw48` (`report_id`),
2276 KEY `FKbquuup9f6nyaxe8lialahh54r` (`requestedBy_id`),
2277 KEY `FK6ne2n7c1nm3whon604jo98n1k` (`requestingCommunity_id`),
2278 FULLTEXT KEY `labelIndex` (`verificationLabels`),
2279 CONSTRAINT `FK6ne2n7c1nm3whon604jo98n1k` FOREIGN KEY (`requestingCommunity_id`) REFERENCES `Community` (`id`),
2280 CONSTRAINT `FKbquuup9f6nyaxe8lialahh54r` FOREIGN KEY (`requestedBy_id`) REFERENCES `UserEntity` (`id`),
2281 CONSTRAINT `FKex0gu3dk0loy27kjk1yff261v` FOREIGN KEY (`individual_id`) REFERENCES `Individual` (`id`),
2282 CONSTRAINT `FKsovu3q3gleeuypsabo0uftw48` FOREIGN KEY (`report_id`) REFERENCES `VerificationReportBase` (`id`),
2283 CONSTRAINT `FKsq3rb61vbid8ianb65trwpw33` FOREIGN KEY (`assignedTo_id`) REFERENCES `Personnel` (`id`),
2284 CONSTRAINT `FKt2pm09wy1e7x0ar209iaxl5ov` FOREIGN KEY (`parentCommunity_id`) REFERENCES `Community` (`id`)
2285) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
2286[2019-05-15 13:27:09,405] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.VerificationRequestBase.Value' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.VerificationRequestBase.Value' (io.debezium.connector.mysql.MySqlSchema:170)
2287[2019-05-15 13:27:09,406] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.VerificationRequestBase.Key' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.VerificationRequestBase.Key' (io.debezium.connector.mysql.MySqlSchema:170)
2288[2019-05-15 13:27:09,407] WARN The Kafka Connect schema name 'cdc-lav.AadhaarDB.VerificationRequestBase.Envelope' is not a valid Avro schema name, so replacing with 'cdc_lav.AadhaarDB.VerificationRequestBase.Envelope' (io.debezium.connector.mysql.MySqlSchema:170)
2289[2019-05-15 13:27:09,409] INFO Step 7: releasing global read lock to enable MySQL writes (io.debezium.connector.mysql.SnapshotReader:450)
2290[2019-05-15 13:27:09,411] INFO Step 7: blocked writes to MySQL for a total of 00:00:06.339 (io.debezium.connector.mysql.SnapshotReader:456)
2291[2019-05-15 13:27:09,412] INFO Step 8: scanning contents of 5 tables while still in transaction (io.debezium.connector.mysql.SnapshotReader:473)
2292[2019-05-15 13:27:09,413] INFO Step 8: scanned 0 rows in 5 tables in 00:00:00.001 (io.debezium.connector.mysql.SnapshotReader:601)
2293[2019-05-15 13:27:09,413] INFO Step 9: committing transaction (io.debezium.connector.mysql.SnapshotReader:635)
2294[2019-05-15 13:27:09,415] INFO Completed snapshot in 00:00:06.365 (io.debezium.connector.mysql.SnapshotReader:701)
2295[2019-05-15 13:27:09,510] INFO Transitioning from the snapshot reader to the binlog reader (io.debezium.connector.mysql.ChainedReader:199)
2296[2019-05-15 13:27:09,552] INFO GTID set purged on server: (io.debezium.connector.mysql.BinlogReader:326)
2297[2019-05-15 13:27:09,552] INFO Attempting to generate a filtered GTID set (io.debezium.connector.mysql.MySqlTaskContext:306)
2298[2019-05-15 13:27:09,553] INFO GTID set from previous recorded offset: 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (io.debezium.connector.mysql.MySqlTaskContext:307)
2299[2019-05-15 13:27:09,553] INFO GTID set available on server: 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (io.debezium.connector.mysql.MySqlTaskContext:314)
2300[2019-05-15 13:27:09,553] INFO Final merged GTID set to use when connecting to MySQL: 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (io.debezium.connector.mysql.MySqlTaskContext:335)
2301[2019-05-15 13:27:09,553] INFO Registering binlog reader with GTID set: 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (io.debezium.connector.mysql.BinlogReader:331)
2302[2019-05-15 13:27:09,554] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
2303[2019-05-15 13:27:09,557] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
2304May 15, 2019 1:27:09 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2305INFO: Connected to localhost:3306 at 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (sid:43, cid:268)
2306[2019-05-15 13:27:09,567] INFO Connected to MySQL binlog at localhost:3306, starting at GTIDs 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 and binlog file 'mysql-bin.000009', pos=1542, skipping 0 events plus 0 rows (io.debezium.connector.mysql.BinlogReader:1004)
2307[2019-05-15 13:27:09,568] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
2308[2019-05-15 13:28:02,410] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2309[2019-05-15 13:28:02,417] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2310[2019-05-15 13:28:02,432] INFO WorkerSourceTask{id=cdc-lav-0} Finished commitOffsets successfully in 14 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:497)
2311[2019-05-15 13:29:02,432] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2312[2019-05-15 13:29:02,465] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2313[2019-05-15 13:29:31,078] INFO 0:0:0:0:0:0:0:1 - - [15/May/2019:07:59:31 +0000] "GET /connectors/cdc-lav/status HTTP/1.1" 200 165 16 (org.apache.kafka.connect.runtime.rest.RestServer:60)
2314[2019-05-15 13:29:39,714] ERROR Encountered change event 'Event{header=EventHeaderV4{timestamp=1557907179000, eventType=TABLE_MAP, serverId=43, headerLength=19, dataLength=97, nextPosition=1802, flags=0}, data=TableMapEventData{tableId=126, database='aadhaardb', table='verificationrequestbase', columnTypes=8, 18, 18, 16, 18, 3, 15, 18, 18, 18, 18, 15, 8, 18, 15, 8, 8, 8, 8, 8, 8, 18, -4, 15, columnMetadata=0, 0, 0, 1, 0, 0, 765, 0, 0, 0, 0, 150, 0, 0, 765, 0, 0, 0, 0, 0, 0, 0, 4, 150, columnNullability={1, 2, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23}, eventMetadata=null}}' at offset {ts_sec=1557907179, file=mysql-bin.000009, pos=1607, gtids=0ead3b18-5461-11e9-be5a-846e9abad705:1-5, server_id=43, event=1} for table aadhaardb.verificationrequestbase whose schema isn't known to this connector. One possible cause is an incomplete database history topic. Take a new snapshot in this case.
2315Use the mysqlbinlog tool to view the problematic event: mysqlbinlog --start-position=1686 --stop-position=1802 --verbose mysql-bin.000009 (io.debezium.connector.mysql.BinlogReader:747)
2316[2019-05-15 13:29:39,714] ERROR Error during binlog processing. Last offset stored = null, binlog reader near position = mysql-bin.000009/1686 (io.debezium.connector.mysql.BinlogReader:1054)
2317[2019-05-15 13:29:39,715] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:209)
2318org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
2319 at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
2320 at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
2321 at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
2322 at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
2323 at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
2324 at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
2325 at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
2326 at java.lang.Thread.run(Thread.java:748)
2327Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
2328 at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
2329 at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
2330 at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
2331 ... 5 more
2332[2019-05-15 13:29:39,717] INFO Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. (io.debezium.connector.mysql.BinlogReader:513)
2333[2019-05-15 13:29:40,015] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2334[2019-05-15 13:29:40,016] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2335[2019-05-15 13:29:40,016] ERROR WorkerSourceTask{id=cdc-lav-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177)
2336org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
2337 at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
2338 at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
2339 at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
2340 at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
2341 at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
2342 at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
2343 at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
2344 at java.lang.Thread.run(Thread.java:748)
2345Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
2346 at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
2347 at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
2348 at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
2349 ... 5 more
2350[2019-05-15 13:29:40,016] ERROR WorkerSourceTask{id=cdc-lav-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:178)
2351[2019-05-15 13:29:40,016] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:430)
2352[2019-05-15 13:29:40,017] INFO ChainedReader: Stopping the binlog reader (io.debezium.connector.mysql.ChainedReader:121)
2353[2019-05-15 13:29:40,017] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.BinlogReader:129)
2354[2019-05-15 13:29:40,017] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.BinlogReader:129)
2355[2019-05-15 13:29:40,018] INFO [Producer clientId=cdc-lav-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1139)
2356[2019-05-15 13:29:40,018] INFO Stopped reading binlog after 0 events, no new offset was recorded (io.debezium.connector.mysql.BinlogReader:992)
2357[2019-05-15 13:29:40,021] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask:465)
2358[2019-05-15 13:29:40,022] INFO [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1139)
2359[2019-05-15 13:29:42,078] INFO 0:0:0:0:0:0:0:1 - - [15/May/2019:07:59:42 +0000] "GET /connectors/cdc-lav/status HTTP/1.1" 200 1466 3 (org.apache.kafka.connect.runtime.rest.RestServer:60)
2360[2019-05-15 13:30:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2361[2019-05-15 13:30:02,466] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2362[2019-05-15 13:31:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2363[2019-05-15 13:31:02,466] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2364[2019-05-15 13:32:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2365[2019-05-15 13:32:02,466] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2366[2019-05-15 13:33:02,467] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2367[2019-05-15 13:33:02,467] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
2368[2019-05-15 13:34:02,469] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
2369[2019-05-15 13:34:02,469] INFO WorkerSourceTask{id=cdc-lav-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)