Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [2019-05-15 13:26:03,758] INFO WorkerInfo values:
- 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
- jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_201, 25.201-b09
- 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/*
- os.spec = Mac OS X, x86_64, 10.14.4
- os.vcpus = 8
- (org.apache.kafka.connect.runtime.WorkerInfo:71)
- [2019-05-15 13:26:03,777] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:89)
- [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)
- [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)
- [2019-05-15 13:26:04,871] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,871] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,872] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,873] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,875] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:04,877] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:08,475] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:08,475] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:09,624] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:09,624] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:19,669] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:19,669] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:22,376] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:22,376] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [2019-05-15 13:26:22,739] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:22,740] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:25,988] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:25,989] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:167)
- [2019-05-15 13:26:27,407] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:238)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:27,433] INFO DistributedConfig values:
- access.control.allow.methods =
- access.control.allow.origin =
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id =
- config.providers = []
- config.storage.replication.factor = 1
- config.storage.topic = connect-configs
- connections.max.idle.ms = 540000
- group.id = connect-cluster
- header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
- heartbeat.interval.ms = 3000
- internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
- internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
- key.converter = class io.confluent.connect.avro.AvroConverter
- listeners = null
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- offset.flush.interval.ms = 60000
- offset.flush.timeout.ms = 5000
- offset.storage.partitions = 25
- offset.storage.replication.factor = 1
- offset.storage.topic = connect-offsets
- plugin.path = [/Users/OnGrid/Documents/kafka/confluent-platform/share/java, /Users/OnGrid/Documents/kafka/confluent-platform/share/confluent-hub-components]
- rebalance.timeout.ms = 60000
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 40000
- rest.advertised.host.name = null
- rest.advertised.listener = null
- rest.advertised.port = null
- rest.extension.classes = []
- rest.host.name = null
- rest.port = 8083
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- session.timeout.ms = 10000
- ssl.cipher.suites = null
- ssl.client.auth = none
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- status.storage.partitions = 5
- status.storage.replication.factor = 1
- status.storage.topic = connect-statuses
- task.shutdown.graceful.timeout.ms = 5000
- value.converter = class io.confluent.connect.avro.AvroConverter
- worker.sync.timeout.ms = 3000
- worker.unsync.backoff.ms = 300000
- (org.apache.kafka.connect.runtime.distributed.DistributedConfig:279)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:27,436] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
- [2019-05-15 13:26:27,444] INFO AdminClientConfig values:
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- (org.apache.kafka.clients.admin.AdminClientConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:27,493] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:27,493] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:27,670] INFO Kafka cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.connect.util.ConnectUtils:59)
- [2019-05-15 13:26:27,692] INFO Logging initialized @29502ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
- [2019-05-15 13:26:27,740] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:120)
- [2019-05-15 13:26:27,741] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:164)
- [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)
- [2019-05-15 13:26:27,866] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
- [2019-05-15 13:26:27,866] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
- [2019-05-15 13:26:27,868] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
- May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
- WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored.
- May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
- WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored.
- May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
- WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored.
- May 15, 2019 1:26:28 PM org.glassfish.jersey.internal.Errors logErrors
- WARNING: The following warnings have been detected: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
- WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
- WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
- WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
- [2019-05-15 13:26:28,520] INFO Started o.e.j.s.ServletContextHandler@65eb76cd{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
- [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)
- [2019-05-15 13:26:28,558] INFO Started @30367ms (org.eclipse.jetty.server.Server:407)
- [2019-05-15 13:26:38,567] INFO Advertised URI: http://192.168.1.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:271)
- [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)
- [2019-05-15 13:26:43,576] INFO Advertised URI: http://192.168.1.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:271)
- [2019-05-15 13:26:43,589] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:43,589] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:43,723] INFO JsonConverterConfig values:
- converter.type = key
- schemas.cache.size = 1000
- schemas.enable = false
- (org.apache.kafka.connect.json.JsonConverterConfig:279)
- [2019-05-15 13:26:43,725] INFO JsonConverterConfig values:
- converter.type = value
- schemas.cache.size = 1000
- schemas.enable = false
- (org.apache.kafka.connect.json.JsonConverterConfig:279)
- [2019-05-15 13:26:43,765] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:43,765] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:43,768] INFO Kafka Connect distributed worker initialization took 39992ms (org.apache.kafka.connect.cli.ConnectDistributed:124)
- [2019-05-15 13:26:43,768] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
- [2019-05-15 13:26:43,768] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)
- [2019-05-15 13:26:43,768] INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:212)
- [2019-05-15 13:26:43,769] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:162)
- [2019-05-15 13:26:43,769] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108)
- [2019-05-15 13:26:43,769] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:125)
- [2019-05-15 13:26:43,769] INFO AdminClientConfig values:
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- (org.apache.kafka.clients.admin.AdminClientConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:43,774] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:43,774] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:26:44,287] INFO ProducerConfig values:
- acks = all
- batch.size = 16384
- bootstrap.servers = [localhost:9092]
- buffer.memory = 33554432
- client.dns.lookup = default
- client.id =
- compression.type = none
- connections.max.idle.ms = 540000
- delivery.timeout.ms = 2147483647
- enable.idempotence = false
- interceptor.classes = []
- key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- linger.ms = 0
- max.block.ms = 60000
- max.in.flight.requests.per.connection = 1
- max.request.size = 1048576
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retries = 2147483647
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- transaction.timeout.ms = 60000
- transactional.id = null
- value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- (org.apache.kafka.clients.producer.ProducerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,315] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,315] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:44,326] INFO ConsumerConfig values:
- auto.commit.interval.ms = 5000
- auto.offset.reset = earliest
- bootstrap.servers = [localhost:9092]
- check.crcs = true
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 540000
- default.api.timeout.ms = 60000
- enable.auto.commit = false
- exclude.internal.topics = true
- fetch.max.bytes = 52428800
- fetch.max.wait.ms = 500
- fetch.min.bytes = 1
- group.id = connect-cluster
- heartbeat.interval.ms = 3000
- interceptor.classes = []
- internal.leave.group.on.close = true
- isolation.level = read_uncommitted
- key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
- max.partition.fetch.bytes = 1048576
- max.poll.interval.ms = 300000
- max.poll.records = 500
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- session.timeout.ms = 10000
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
- (org.apache.kafka.clients.consumer.ConsumerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,359] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,359] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:26:44,412] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [2019-05-15 13:26:44,414] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,454] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:158)
- [2019-05-15 13:26:44,455] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:160)
- [2019-05-15 13:26:44,455] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110)
- [2019-05-15 13:26:44,456] INFO Worker started (org.apache.kafka.connect.runtime.Worker:167)
- [2019-05-15 13:26:44,457] INFO Starting KafkaBasedLog with topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:125)
- [2019-05-15 13:26:44,457] INFO AdminClientConfig values:
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- (org.apache.kafka.clients.admin.AdminClientConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,466] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,467] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:26:44,608] INFO ProducerConfig values:
- acks = all
- batch.size = 16384
- bootstrap.servers = [localhost:9092]
- buffer.memory = 33554432
- client.dns.lookup = default
- client.id =
- compression.type = none
- connections.max.idle.ms = 540000
- delivery.timeout.ms = 120000
- enable.idempotence = false
- interceptor.classes = []
- key.serializer = class org.apache.kafka.common.serialization.StringSerializer
- linger.ms = 0
- max.block.ms = 60000
- max.in.flight.requests.per.connection = 1
- max.request.size = 1048576
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retries = 0
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- transaction.timeout.ms = 60000
- transactional.id = null
- value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- (org.apache.kafka.clients.producer.ProducerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,617] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,618] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:44,619] INFO ConsumerConfig values:
- auto.commit.interval.ms = 5000
- auto.offset.reset = earliest
- bootstrap.servers = [localhost:9092]
- check.crcs = true
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 540000
- default.api.timeout.ms = 60000
- enable.auto.commit = false
- exclude.internal.topics = true
- fetch.max.bytes = 52428800
- fetch.max.wait.ms = 500
- fetch.min.bytes = 1
- group.id = connect-cluster
- heartbeat.interval.ms = 3000
- interceptor.classes = []
- internal.leave.group.on.close = true
- isolation.level = read_uncommitted
- key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
- max.partition.fetch.bytes = 1048576
- max.poll.interval.ms = 300000
- max.poll.records = 500
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- session.timeout.ms = 10000
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
- (org.apache.kafka.clients.consumer.ConsumerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,628] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,628] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:26:44,645] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,664] INFO Finished reading KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:158)
- [2019-05-15 13:26:44,664] INFO Started KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:160)
- [2019-05-15 13:26:44,665] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:248)
- [2019-05-15 13:26:44,665] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:125)
- [2019-05-15 13:26:44,666] INFO AdminClientConfig values:
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 5
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- (org.apache.kafka.clients.admin.AdminClientConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,673] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,673] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:44,718] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [2019-05-15 13:26:44,752] INFO ProducerConfig values:
- acks = all
- batch.size = 16384
- bootstrap.servers = [localhost:9092]
- buffer.memory = 33554432
- client.dns.lookup = default
- client.id =
- compression.type = none
- connections.max.idle.ms = 540000
- delivery.timeout.ms = 2147483647
- enable.idempotence = false
- interceptor.classes = []
- key.serializer = class org.apache.kafka.common.serialization.StringSerializer
- linger.ms = 0
- max.block.ms = 60000
- max.in.flight.requests.per.connection = 1
- max.request.size = 1048576
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retries = 2147483647
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- transaction.timeout.ms = 60000
- transactional.id = null
- value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- (org.apache.kafka.clients.producer.ProducerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,760] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,761] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:26:44,761] INFO ConsumerConfig values:
- auto.commit.interval.ms = 5000
- auto.offset.reset = earliest
- bootstrap.servers = [localhost:9092]
- check.crcs = true
- client.dns.lookup = default
- client.id =
- connections.max.idle.ms = 540000
- default.api.timeout.ms = 60000
- enable.auto.commit = false
- exclude.internal.topics = true
- fetch.max.bytes = 52428800
- fetch.max.wait.ms = 500
- fetch.min.bytes = 1
- group.id = connect-cluster
- heartbeat.interval.ms = 3000
- interceptor.classes = []
- internal.leave.group.on.close = true
- isolation.level = read_uncommitted
- key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
- max.partition.fetch.bytes = 1048576
- max.poll.interval.ms = 300000
- max.poll.records = 500
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- session.timeout.ms = 10000
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
- (org.apache.kafka.clients.consumer.ConsumerConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:44,768] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:26:44,768] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:26:44,786] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [2019-05-15 13:26:44,794] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:158)
- [2019-05-15 13:26:44,794] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:160)
- [2019-05-15 13:26:44,795] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:253)
- [2019-05-15 13:26:44,795] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:216)
- [2019-05-15 13:26:44,804] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [2019-05-15 13:26:44,871] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:26:46,048] INFO Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
- [2019-05-15 13:26:46,048] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
- [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)
- [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)
- [2019-05-15 13:27:00,357] INFO Connector cdc-lav config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1097)
- [2019-05-15 13:27:00,856] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238)
- [2019-05-15 13:27:00,856] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:00,907] INFO Starting connectors and tasks using config offset 1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
- [2019-05-15 13:27:00,908] INFO Starting connector cdc-lav (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904)
- [2019-05-15 13:27:00,909] INFO ConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig:279)
- [2019-05-15 13:27:00,910] INFO EnrichedConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
- [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)
- [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)
- [2019-05-15 13:27:00,923] INFO Finished creating connector cdc-lav (org.apache.kafka.connect.runtime.Worker:247)
- [2019-05-15 13:27:00,924] INFO SourceConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)
- [2019-05-15 13:27:00,925] INFO EnrichedConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
- [2019-05-15 13:27:01,873] INFO Tasks [cdc-lav-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1112)
- [2019-05-15 13:27:02,376] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
- [2019-05-15 13:27:02,377] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1238)
- [2019-05-15 13:27:02,378] INFO Stopping connector cdc-lav (org.apache.kafka.connect.runtime.Worker:328)
- [2019-05-15 13:27:02,379] INFO Stopped connector cdc-lav (org.apache.kafka.connect.runtime.Worker:344)
- [2019-05-15 13:27:02,382] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1268)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:02,388] INFO Starting connectors and tasks using config offset 3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:850)
- [2019-05-15 13:27:02,389] INFO Starting connector cdc-lav (org.apache.kafka.connect.runtime.distributed.DistributedHerder:904)
- [2019-05-15 13:27:02,389] INFO Starting task cdc-lav-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:864)
- [2019-05-15 13:27:02,389] INFO ConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig:279)
- [2019-05-15 13:27:02,389] INFO Creating task cdc-lav-0 (org.apache.kafka.connect.runtime.Worker:386)
- [2019-05-15 13:27:02,389] INFO EnrichedConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
- [2019-05-15 13:27:02,390] INFO ConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig:279)
- [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)
- [2019-05-15 13:27:02,390] INFO EnrichedConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
- [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)
- [2019-05-15 13:27:02,391] INFO Finished creating connector cdc-lav (org.apache.kafka.connect.runtime.Worker:247)
- [2019-05-15 13:27:02,392] INFO SourceConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)
- [2019-05-15 13:27:02,392] INFO TaskConfig values:
- task.class = class io.debezium.connector.mysql.MySqlConnectorTask
- (org.apache.kafka.connect.runtime.TaskConfig:279)
- [2019-05-15 13:27:02,392] INFO EnrichedConnectorConfig values:
- config.action.reload = restart
- connector.class = io.debezium.connector.mysql.MySqlConnector
- errors.log.enable = false
- errors.log.include.messages = false
- errors.retry.delay.max.ms = 60000
- errors.retry.timeout = 0
- errors.tolerance = none
- header.converter = null
- key.converter = class org.apache.kafka.connect.json.JsonConverter
- name = cdc-lav
- tasks.max = 1
- transforms = []
- value.converter = class org.apache.kafka.connect.json.JsonConverter
- (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
- [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)
- [2019-05-15 13:27:02,393] INFO JsonConverterConfig values:
- converter.type = key
- schemas.cache.size = 1000
- schemas.enable = false
- (org.apache.kafka.connect.json.JsonConverterConfig:279)
- [2019-05-15 13:27:02,394] INFO JsonConverterConfig values:
- converter.type = value
- schemas.cache.size = 1000
- schemas.enable = false
- (org.apache.kafka.connect.json.JsonConverterConfig:279)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:02,399] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:486)
- [2019-05-15 13:27:02,401] INFO ProducerConfig values:
- acks = all
- batch.size = 16384
- bootstrap.servers = [localhost:9092]
- buffer.memory = 33554432
- client.dns.lookup = default
- client.id =
- compression.type = none
- connections.max.idle.ms = 540000
- delivery.timeout.ms = 2147483647
- enable.idempotence = false
- interceptor.classes = []
- key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- linger.ms = 0
- max.block.ms = 9223372036854775807
- max.in.flight.requests.per.connection = 1
- max.request.size = 1048576
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 2147483647
- retries = 2147483647
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- transaction.timeout.ms = 60000
- transactional.id = null
- value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
- (org.apache.kafka.clients.producer.ProducerConfig:279)
- [2019-05-15 13:27:02,404] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:27:02,404] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:27:02,410] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:860)
- [2019-05-15 13:27:02,413] INFO Starting MySqlConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:43)
- [2019-05-15 13:27:02,415] INFO connector.class = io.debezium.connector.mysql.MySqlConnector (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.user = debezium (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.server.id = 43 (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.history.kafka.bootstrap.servers = localhost:9092 (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.history.kafka.topic = lav.history (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.server.name = cdc-lav (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,415] INFO database.port = 3306 (io.debezium.connector.common.BaseSourceTask:45)
- [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)
- [2019-05-15 13:27:02,416] INFO key.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO task.class = io.debezium.connector.mysql.MySqlConnectorTask (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO database.hostname = localhost (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO name = cdc-lav (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO database.whitelist = aadhaardb (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,416] INFO key.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask:45)
- [2019-05-15 13:27:02,505] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [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)
- [2019-05-15 13:27:02,883] INFO ProducerConfig values:
- acks = 1
- batch.size = 32768
- bootstrap.servers = [localhost:9092]
- buffer.memory = 1048576
- client.dns.lookup = default
- client.id = cdc-lav-dbhistory
- compression.type = none
- connections.max.idle.ms = 540000
- delivery.timeout.ms = 120000
- enable.idempotence = false
- interceptor.classes = []
- key.serializer = class org.apache.kafka.common.serialization.StringSerializer
- linger.ms = 0
- max.block.ms = 10000
- max.in.flight.requests.per.connection = 5
- max.request.size = 1048576
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
- receive.buffer.bytes = 32768
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 30000
- retries = 1
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- transaction.timeout.ms = 60000
- transactional.id = null
- value.serializer = class org.apache.kafka.common.serialization.StringSerializer
- (org.apache.kafka.clients.producer.ProducerConfig:279)
- [2019-05-15 13:27:02,886] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:27:02,887] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [2019-05-15 13:27:02,888] INFO AdminClientConfig values:
- bootstrap.servers = [localhost:9092]
- client.dns.lookup = default
- client.id = cdc-lav-dbhistory
- connections.max.idle.ms = 300000
- metadata.max.age.ms = 300000
- metric.reporters = []
- metrics.num.samples = 2
- metrics.recording.level = INFO
- metrics.sample.window.ms = 30000
- receive.buffer.bytes = 65536
- reconnect.backoff.max.ms = 1000
- reconnect.backoff.ms = 50
- request.timeout.ms = 120000
- retries = 1
- retry.backoff.ms = 100
- sasl.client.callback.handler.class = null
- sasl.jaas.config = null
- sasl.kerberos.kinit.cmd = /usr/bin/kinit
- sasl.kerberos.min.time.before.relogin = 60000
- sasl.kerberos.service.name = null
- sasl.kerberos.ticket.renew.jitter = 0.05
- sasl.kerberos.ticket.renew.window.factor = 0.8
- sasl.login.callback.handler.class = null
- sasl.login.class = null
- sasl.login.refresh.buffer.seconds = 300
- sasl.login.refresh.min.period.seconds = 60
- sasl.login.refresh.window.factor = 0.8
- sasl.login.refresh.window.jitter = 0.05
- sasl.mechanism = GSSAPI
- security.protocol = PLAINTEXT
- send.buffer.bytes = 131072
- ssl.cipher.suites = null
- ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
- ssl.endpoint.identification.algorithm = https
- ssl.key.password = null
- ssl.keymanager.algorithm = SunX509
- ssl.keystore.location = null
- ssl.keystore.password = null
- ssl.keystore.type = JKS
- ssl.protocol = TLS
- ssl.provider = null
- ssl.secure.random.implementation = null
- ssl.trustmanager.algorithm = PKIX
- ssl.truststore.location = null
- ssl.truststore.password = null
- ssl.truststore.type = JKS
- (org.apache.kafka.clients.admin.AdminClientConfig:279)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:02,892] INFO Kafka version: 2.2.0-cp2 (org.apache.kafka.common.utils.AppInfoParser:109)
- [2019-05-15 13:27:02,892] INFO Kafka commitId: 325e9879cbc6d612 (org.apache.kafka.common.utils.AppInfoParser:110)
- [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)
- [2019-05-15 13:27:02,992] INFO Found no existing offset, so preparing to perform a snapshot (io.debezium.connector.mysql.MySqlConnectorTask:160)
- [2019-05-15 13:27:02,994] INFO Cluster ID: DhdWen8-SsCMIw-QwURJ1g (org.apache.kafka.clients.Metadata:365)
- [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)
- [2019-05-15 13:27:03,048] INFO Requested thread factory for connector MySqlConnector, id = cdc-lav named = snapshot (io.debezium.util.Threads:250)
- [2019-05-15 13:27:03,049] INFO Creating thread debezium-mysqlconnector-cdc-lav-snapshot (io.debezium.util.Threads:267)
- [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)
- [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)
- [2019-05-15 13:27:03,052] INFO Snapshot is using user 'debezium' with these MySQL grants: (io.debezium.connector.mysql.SnapshotReader:851)
- [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)
- [2019-05-15 13:27:03,053] INFO MySQL server variables related to change data capture: (io.debezium.connector.mysql.SnapshotReader:824)
- [2019-05-15 13:27:03,062] INFO binlog_cache_size = 32768 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,062] INFO binlog_checksum = CRC32 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,062] INFO binlog_direct_non_transactional_updates = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,062] INFO binlog_error_action = ABORT_SERVER (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,062] INFO binlog_format = ROW (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,062] INFO binlog_group_commit_sync_delay = 0 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_group_commit_sync_no_delay_count = 0 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_gtid_simple_recovery = ON (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_max_flush_queue_time = 0 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_order_commits = ON (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_row_image = FULL (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_rows_query_log_events = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_stmt_cache_size = 32768 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_transaction_dependency_history_size = 25000 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO binlog_transaction_dependency_tracking = COMMIT_ORDER (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO character_set_client = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,063] INFO character_set_connection = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO character_set_database = latin1 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO character_set_filesystem = binary (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO character_set_results = utf8mb4 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO character_set_server = latin1 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO character_set_system = utf8 (io.debezium.connector.mysql.SnapshotReader:827)
- [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)
- [2019-05-15 13:27:03,064] INFO collation_connection = utf8mb4_general_ci (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO collation_database = latin1_swedish_ci (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO collation_server = latin1_swedish_ci (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO enforce_gtid_consistency = ON (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO gtid_executed_compression_period = 1000 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO gtid_mode = ON (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,064] INFO gtid_next = AUTOMATIC (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO gtid_owned = (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO gtid_purged = (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO innodb_api_enable_binlog = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO innodb_locks_unsafe_for_binlog = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO innodb_version = 5.7.25 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO log_statements_unsafe_for_binlog = ON (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO max_binlog_cache_size = 18446744073709547520 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO max_binlog_size = 1073741824 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO max_binlog_stmt_cache_size = 18446744073709547520 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO protocol_version = 10 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO session_track_gtids = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO slave_type_conversions = (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO sync_binlog = 1 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,065] INFO system_time_zone = IST (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO time_zone = SYSTEM (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO tls_version = TLSv1,TLSv1.1 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO tx_isolation = REPEATABLE-READ (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO tx_read_only = OFF (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO version = 5.7.25-log (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO version_comment = MySQL Community Server (GPL) (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO version_compile_machine = x86_64 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO version_compile_os = macos10.14 (io.debezium.connector.mysql.SnapshotReader:827)
- [2019-05-15 13:27:03,066] INFO Step 0: disabling autocommit and enabling repeatable read transactions (io.debezium.connector.mysql.SnapshotReader:202)
- [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)
- [2019-05-15 13:27:03,071] INFO Step 2: start transaction with consistent snapshot (io.debezium.connector.mysql.SnapshotReader:247)
- [2019-05-15 13:27:03,072] INFO Step 3: read binlog position of MySQL master (io.debezium.connector.mysql.SnapshotReader:742)
- [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)
- [2019-05-15 13:27:03,076] INFO Step 4: read list of available databases (io.debezium.connector.mysql.SnapshotReader:272)
- [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)
- [2019-05-15 13:27:03,248] INFO Step 5: read list of available tables in each database (io.debezium.connector.mysql.SnapshotReader:291)
- [2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVDumpRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVDumpRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVIngestRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVIngestRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,039] INFO 'AadhaarDB.AVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,040] INFO 'AadhaarDB.AadhaarVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AadhaarVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.Acct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctBalHist' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctPybl' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctPyblPmt' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,041] INFO 'AadhaarDB.AcctRcvb' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,042] INFO 'AadhaarDB.AcctRcvbPmt' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,042] INFO 'AadhaarDB.Actv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,042] INFO including 'AadhaarDB.AddressEntity' (io.debezium.connector.mysql.SnapshotReader:310)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.AddressEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.App' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.App_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.AppointmentLetterDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.AppointmentLetterDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,043] INFO 'AadhaarDB.BVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BankEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BankEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.Batch' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.Batch_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BirthCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BirthCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,044] INFO 'AadhaarDB.BoardUniversityDatabase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityEmail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.BoardUniversityPhone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVEvidenceEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVEvidenceEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,045] INFO 'AadhaarDB.CCRVRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CCRVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,046] INFO 'AadhaarDB.CharacterCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.CharacterCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.ClassOfVehicleCode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.Community' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityAccessEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityAccessEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,047] INFO 'AadhaarDB.CommunityActivityEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityConfiguration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityConfiguration_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityDeviceMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityDeviceMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,048] INFO 'AadhaarDB.CommunityIndividualMapping_Batch' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualMapping_Batch_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualNote' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualNote_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualReview' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityIndividualReview_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityInviteEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityInviteEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,049] INFO 'AadhaarDB.CommunityOffering' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOfferingMode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOfferingMode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityOffering_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityServices' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityServices_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityTag' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.CommunityTag_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.Community_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,050] INFO 'AadhaarDB.ConsentResponseEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CovDetailEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CovDetailEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalAct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalAct_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordPetitionerName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordPetitionerName_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordRespondentName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,051] INFO 'AadhaarDB.CriminalRecordRespondentName_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_CriminalAct' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CriminalRecord_CriminalAct_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomSchemaEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.CustomSchemaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.DBReportEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,052] INFO 'AadhaarDB.DBReportEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportEntity_ParametersEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportEntity_ParametersEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportParametersEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DBReportParametersEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DCSMissingField' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,053] INFO 'AadhaarDB.DLVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVReport_CovDetailEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DLVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DataCollectionSchemaEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DataCollectionSchemaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DefaultDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DefaultDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DocumentEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,054] INFO 'AadhaarDB.DocumentEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationReportEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationReportEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DocumentVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DriverLicenceCategory' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DriverLicenceCategory_VehicleClass' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DrivingLicenceDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.DrivingLicenceDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.EDUVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,055] INFO 'AadhaarDB.EDUVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EDUVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EMPVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EdVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,056] INFO 'AadhaarDB.EdVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationDetailDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationDetailDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EducationVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmpVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmpVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerDatabase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerEmail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,057] INFO 'AadhaarDB.EmployerName' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmployerPhone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentRecord_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.EmploymentVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExotelTelecomDetails' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExotelTelecomDetails_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExperienceLetter' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.ExperienceLetter_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,058] INFO 'AadhaarDB.FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.FinanceInformationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.FinanceInformationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.GasConnectionDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.GasConnectionDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IVRMessage' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IVRMessage_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.Individual' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualAadhaarData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualAadhaarData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualBiometricVerification' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualBiometricVerification_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,059] INFO 'AadhaarDB.IndividualCommunityTagValue' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualCommunityTagValue_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualConsent' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualConsentAudit' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualRegistrationInvite' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualRegistrationInvite_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerification' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerificationCode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerificationCode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.IndividualVerification_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_Profession' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,060] INFO 'AadhaarDB.Individual_Profession_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.InstaveritasVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyOfferingMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyOfferingMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyReason' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.InsufficiencyReason_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVImageMigrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVMockLocationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVMockLocationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_ReferenceFileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVReport_ReferenceFileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,061] INFO 'AadhaarDB.LAVRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO including 'AadhaarDB.LAVerificationRequest' (io.debezium.connector.mysql.SnapshotReader:310)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LAVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorization' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorizationResponseEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LetterOfAuthorization_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,062] INFO 'AadhaarDB.LicenceVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationEntity_LicenceVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.LicenceVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.LogTable' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.NonAadhaarData' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.NonAadhaarData_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.Offering' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.OfferingMode' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.OfferingMode_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.Offering_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.OnGridService' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.OnGridService_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.PANCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,063] INFO 'AadhaarDB.PANCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PANVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,064] INFO 'AadhaarDB.PCCVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PCCVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PRCRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,065] INFO 'AadhaarDB.PVLFVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmRequestEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmRequestEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PVLawFirmVerificationReport_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PassportDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PassportDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO including 'AadhaarDB.Personnel' (io.debezium.connector.mysql.SnapshotReader:310)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelDeviceRegistrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelDeviceRegistrationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelRuleViolationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelRuleViolationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,066] INFO 'AadhaarDB.PersonnelServiceAreaDetails' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PersonnelServiceAreaDetails_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO including 'AadhaarDB.PersonnelServiceAreaEntity' (io.debezium.connector.mysql.SnapshotReader:310)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PersonnelServiceAreaEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.Personnel_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PhoneConversation' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PhoneConversation_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PincodeLocationMapping' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PincodeLocationMapping_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PoliceVerificationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.PoliceVerificationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,067] INFO 'AadhaarDB.ProcedureTaskEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.ProcedureTaskEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.Profession' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.Profession_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RCVerificationRecord' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.REVCHANGES' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RationCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RationCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RecommendationLetter' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.RecommendationLetter_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,068] INFO 'AadhaarDB.ReferenceProvider' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.ReferenceProvider_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.RegisteredDeviceEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.RegisteredDeviceEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.RentAgreementDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.RentAgreementDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.ResourceAccessRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.ResourceAccessRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.RevisionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SalarySlipDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SalarySlipDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegActionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegActionEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegLifeCycleEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegLifeCycleEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,069] INFO 'AadhaarDB.SelfRegistrationAction' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.SelfRegistrationAction_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.SkillCertificateDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.SkillCertificateDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.TextMessage' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.TransactionEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserBookmarkEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserBookmarkEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserFeedbackEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserFeedbackEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserRegistrationEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UserRegistrationEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,070] INFO 'AadhaarDB.UtilityBillEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.UtilityBillEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVReport' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVReport_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVerificationRequest' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VIDVerificationRequest_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleClass' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleRegistrationDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VehicleRegistrationDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_FileEntity' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionLog_FileEntity_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionRule' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,071] INFO 'AadhaarDB.VerificationActionRule_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationCompletionEmailDetail' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationCompletionEmailLog' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationInsufficiency' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationInsufficiency_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationLabel' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationLabel_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationReportBase' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationReportBase_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO including 'AadhaarDB.VerificationRequestBase' (io.debezium.connector.mysql.SnapshotReader:310)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestBase_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestInsufficiencies' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VerificationRequestInsufficiencies_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,072] INFO 'AadhaarDB.VoterCardDocument' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.VoterCardDocument_AUD' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.acctNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.actvNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.address_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.avdump_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.avingest_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.batch_id_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.bookmarkId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvevidence_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvreport_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.ccrvrequest_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.commtag_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.community_access_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,073] INFO 'AadhaarDB.community_activity_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_individual_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_note_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.community_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.communityservicesId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.customdata_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.datacollection_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.dbreportentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.dbreportparametersentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.dcmissingfield_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.document_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.documentverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.documentverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.driverLicenceCategoryId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.educationform_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,074] INFO 'AadhaarDB.educationverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.educationverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.employment_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentform_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentverificationreport_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.employmentverificationrequest_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.hibernate_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.incident_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.individualId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.indiviudalconsentaudit_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.insufficiency_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.laverification_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.lavmock_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.lavrequest_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.licenceVerificationId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,075] INFO 'AadhaarDB.licenceVerificationRecordId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.nonaadhaarindividualId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.offeringId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.ongridservicesId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.pccrequestentity_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.pccverificationreport_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.personnelservicearea_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.phoneconversation_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.pincodelocation_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.procedureinitiatorentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.pvlawfirmrequestentity_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.pvlawfirmverificationreport_id_generator_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.refprovider_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.registration_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.reviewAccess_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,076] INFO 'AadhaarDB.selfregaction_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.selfreglifecycle_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.telecomdetails_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.transactionNbr_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.uidverrep_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.uidverreq_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.user_feedback_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.user_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.vehicleClassId_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.verification_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationinsufficiency_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationlabel_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationlog_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.verificationrule_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,077] INFO 'AadhaarDB.violationentity_map_sequence' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,241] INFO 'employees.departments' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,241] INFO 'employees.dept_emp' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,241] INFO 'employees.dept_manager' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,242] INFO 'employees.employees' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,242] INFO 'employees.employees_copy' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,242] INFO 'employees.salaries' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,242] INFO 'employees.titles' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,494] INFO 'mysql.columns_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,494] INFO 'mysql.db' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,494] INFO 'mysql.engine_cost' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.event' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.func' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.general_log' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.gtid_executed' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.help_category' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.help_keyword' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.help_relation' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.help_topic' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.innodb_index_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.innodb_table_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,495] INFO 'mysql.ndb_binlog_index' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.plugin' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.proc' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.procs_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.proxies_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.server_cost' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.servers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.slave_master_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.slave_relay_log_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.slave_worker_info' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.slow_log' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.tables_priv' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,496] INFO 'mysql.time_zone' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,497] INFO 'mysql.time_zone_leap_second' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,497] INFO 'mysql.time_zone_name' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,497] INFO 'mysql.time_zone_transition' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,497] INFO 'mysql.time_zone_transition_type' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,497] INFO 'mysql.user' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,688] INFO 'performance_schema.accounts' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,688] INFO 'performance_schema.cond_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_stages_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,689] INFO 'performance_schema.events_statements_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,690] INFO 'performance_schema.events_transactions_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_current' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_history' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,691] INFO 'performance_schema.events_waits_history_long' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.file_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.file_summary_by_instance' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.global_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.global_variables' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.host_cache' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,692] INFO 'performance_schema.hosts' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.metadata_locks' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.mutex_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.performance_timers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.prepared_statements_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_configuration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.replication_applier_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.replication_connection_configuration' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,693] INFO 'performance_schema.replication_connection_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.replication_group_member_stats' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.replication_group_members' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.rwlock_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.session_account_connect_attrs' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.session_connect_attrs' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.session_status' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.session_variables' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.setup_actors' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.setup_consumers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.setup_instruments' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,694] INFO 'performance_schema.setup_objects' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.setup_timers' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.socket_instances' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.socket_summary_by_instance' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_account' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_host' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.status_by_user' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,695] INFO 'performance_schema.table_handles' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:07,696] INFO 'performance_schema.threads' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,696] INFO 'performance_schema.user_variables_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,696] INFO 'performance_schema.users' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:07,696] INFO 'performance_schema.variables_by_thread' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:08,073] INFO 'sys.sys_config' is filtered out, discarding (io.debezium.connector.mysql.SnapshotReader:312)
- [2019-05-15 13:27:08,077] INFO snapshot continuing with database(s): [AadhaarDB] (io.debezium.connector.mysql.SnapshotReader:338)
- [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)
- [2019-05-15 13:27:08,871] INFO SET character_set_server=latin1, collation_server=latin1_swedish_ci; (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,922] INFO DROP TABLE IF EXISTS `AadhaarDB`.`VerificationRequestBase` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,927] INFO DROP TABLE IF EXISTS `AadhaarDB`.`LAVerificationRequest` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,932] INFO DROP TABLE IF EXISTS `AadhaarDB`.`AddressEntity` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,936] INFO DROP TABLE IF EXISTS `AadhaarDB`.`Personnel` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,940] INFO DROP TABLE IF EXISTS `AadhaarDB`.`PersonnelServiceAreaEntity` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,950] INFO DROP DATABASE IF EXISTS `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,959] INFO CREATE DATABASE `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
- [2019-05-15 13:27:08,967] INFO USE `AadhaarDB` (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [2019-05-15 13:27:09,095] INFO CREATE TABLE `AddressEntity` (
- `id` bigint(20) NOT NULL AUTO_INCREMENT,
- `created` datetime NOT NULL,
- `updated` datetime NOT NULL,
- `co` varchar(255) DEFAULT NULL,
- `district` varchar(255) DEFAULT NULL,
- `entityId` varchar(255) NOT NULL,
- `entityType` varchar(255) NOT NULL,
- `landmark` varchar(255) DEFAULT NULL,
- `latitude` double DEFAULT NULL,
- `longitude` double DEFAULT NULL,
- `line1` varchar(255) DEFAULT NULL,
- `line2` varchar(255) DEFAULT NULL,
- `locality` varchar(255) DEFAULT NULL,
- `pincode` varchar(255) DEFAULT NULL,
- `state` varchar(255) DEFAULT NULL,
- `vtc` varchar(255) DEFAULT NULL,
- `vendor` varchar(255) DEFAULT NULL,
- `verificationRequestId` bigint(20) DEFAULT NULL,
- `verificationRequestStatus` varchar(255) DEFAULT NULL,
- `verificationStatus` varchar(255) DEFAULT NULL,
- `fullAddress` varchar(255) DEFAULT NULL,
- `referredDocuments` varchar(255) DEFAULT NULL,
- `manuallyUpdated` bit(1) NOT NULL,
- `lFullAddress` varchar(255) DEFAULT NULL,
- `lnCode` varchar(255) DEFAULT NULL,
- `locationPoint` geometry DEFAULT NULL,
- `locationType` varchar(255) DEFAULT NULL,
- `addressType` varchar(255) DEFAULT NULL,
- PRIMARY KEY (`id`),
- KEY `is_entityType` (`id`,`entityType`),
- KEY `id_entityId__entityType` (`id`,`entityId`,`entityType`)
- ) ENGINE=InnoDB AUTO_INCREMENT=87091 DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,230] INFO CREATE TABLE `LAVerificationRequest` (
- `note` varchar(255) DEFAULT NULL,
- `verificationResult` varchar(255) DEFAULT NULL,
- `id` bigint(20) NOT NULL,
- `address_id` bigint(20) NOT NULL,
- PRIMARY KEY (`id`),
- KEY `FKncuu1mr7ca7ay5pox50rajjyl` (`address_id`),
- CONSTRAINT `FK91oesj28nsxuwd1ckt2qmmo49` FOREIGN KEY (`id`) REFERENCES `VerificationRequestBase` (`id`),
- CONSTRAINT `FKncuu1mr7ca7ay5pox50rajjyl` FOREIGN KEY (`address_id`) REFERENCES `AddressEntity` (`id`)
- ) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,328] INFO CREATE TABLE `Personnel` (
- `id` bigint(20) NOT NULL AUTO_INCREMENT,
- `aadhaarNumber` varchar(255) DEFAULT NULL,
- `accessToken` varchar(255) NOT NULL,
- `email` varchar(255) NOT NULL,
- `gender` varchar(255) NOT NULL,
- `isActive` bit(1) NOT NULL,
- `name` varchar(255) NOT NULL,
- `phone` varchar(255) NOT NULL,
- `type` varchar(255) NOT NULL,
- `city` varchar(255) NOT NULL,
- `supervisor_id` bigint(20) DEFAULT NULL,
- `Personnel_id` bigint(20) DEFAULT NULL,
- `bankAccountHolderName` varchar(255) DEFAULT NULL,
- `bankAccountIFSCCode` varchar(255) DEFAULT NULL,
- `bankAccountNumber` varchar(255) DEFAULT NULL,
- `bankName` varchar(255) DEFAULT NULL,
- `profileImageUrl` varchar(255) DEFAULT NULL,
- `upiAddress` varchar(255) DEFAULT NULL,
- `unitVerificationPrice` int(11) NOT NULL,
- `gpsStatus` bit(1) NOT NULL,
- `appVersion` int(11) NOT NULL,
- `created` datetime DEFAULT NULL,
- `updated` datetime DEFAULT NULL,
- `bankAccountBranchName` varchar(255) DEFAULT NULL,
- `payToSupervisor` tinyint(1) DEFAULT '0',
- `consentText` longtext NOT NULL,
- `source` char(20) NOT NULL DEFAULT 'Odin',
- `individual_id` bigint(20) DEFAULT NULL,
- `lastSeen` datetime DEFAULT NULL,
- `groupNotificationKey` varchar(255) DEFAULT NULL,
- `personnelGCMID` longtext,
- `documentId` varchar(255) DEFAULT NULL,
- `documentURL` varchar(255) DEFAULT NULL,
- `documentType` varchar(255) DEFAULT NULL,
- `inactiveReason` varchar(255) DEFAULT NULL,
- `individualId` bigint(20) DEFAULT NULL,
- `alternatePhone` varchar(255) DEFAULT NULL,
- `telecomCircle` varchar(255) DEFAULT NULL,
- PRIMARY KEY (`id`),
- UNIQUE KEY `UK_rt8lmrna0tfd1j1rde43w3idl` (`accessToken`),
- UNIQUE KEY `UK_lx6un5vnx6694ljd4qyxpwqlf` (`email`),
- UNIQUE KEY `UK_1wjgkg0ywos5vwyfmt9nqkevh` (`phone`),
- UNIQUE KEY `UK_g6b5ofiqra1wif1rcwqv3l3bb` (`alternatePhone`),
- KEY `FKndogdsmk4bpywt3i1ysb481si` (`supervisor_id`),
- CONSTRAINT `FKndogdsmk4bpywt3i1ysb481si` FOREIGN KEY (`supervisor_id`) REFERENCES `Personnel` (`id`),
- CONSTRAINT `FKnet2cwtxnkqfk16dx0dsi8ci1` FOREIGN KEY (`supervisor_id`) REFERENCES `Personnel` (`id`)
- ) ENGINE=InnoDB AUTO_INCREMENT=249 DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,364] INFO CREATE TABLE `PersonnelServiceAreaEntity` (
- `id` bigint(20) NOT NULL,
- `created` datetime DEFAULT NULL,
- `updated` datetime DEFAULT NULL,
- `deleted` bit(1) NOT NULL,
- `personnel_id` bigint(20) DEFAULT NULL,
- `pincode` varchar(255) NOT NULL,
- `point` geometry NOT NULL,
- PRIMARY KEY (`id`),
- KEY `FKgxfx9qwhpreeth3i7p92k5ldk` (`personnel_id`),
- CONSTRAINT `FKgxfx9qwhpreeth3i7p92k5ldk` FOREIGN KEY (`personnel_id`) REFERENCES `Personnel` (`id`)
- ) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,401] INFO CREATE TABLE `VerificationRequestBase` (
- `id` bigint(20) NOT NULL,
- `created` datetime DEFAULT NULL,
- `updated` datetime DEFAULT NULL,
- `deleted` bit(1) NOT NULL,
- `closedDate` datetime DEFAULT NULL,
- `closedReason` int(11) DEFAULT NULL,
- `closedRemarks` varchar(255) DEFAULT NULL,
- `completedDate` datetime DEFAULT NULL,
- `dataSufficiencyDate` datetime DEFAULT NULL,
- `initiationDate` datetime DEFAULT NULL,
- `lastActionDate` datetime DEFAULT NULL,
- `offeringCode` varchar(50) NOT NULL,
- `onHoldHours` bigint(20) DEFAULT NULL,
- `onHoldSince` datetime DEFAULT NULL,
- `state` varchar(255) DEFAULT NULL,
- `assignedTo_id` bigint(20) DEFAULT NULL,
- `individual_id` bigint(20) DEFAULT NULL,
- `parentCommunity_id` bigint(20) DEFAULT NULL,
- `report_id` bigint(20) DEFAULT NULL,
- `requestedBy_id` bigint(20) DEFAULT NULL,
- `requestingCommunity_id` bigint(20) DEFAULT NULL,
- `submittedDate` datetime DEFAULT NULL,
- `verificationLabels` longtext,
- `offeringMode` varchar(50) DEFAULT NULL,
- PRIMARY KEY (`id`),
- KEY `FKsq3rb61vbid8ianb65trwpw33` (`assignedTo_id`),
- KEY `FKex0gu3dk0loy27kjk1yff261v` (`individual_id`),
- KEY `FKt2pm09wy1e7x0ar209iaxl5ov` (`parentCommunity_id`),
- KEY `FKsovu3q3gleeuypsabo0uftw48` (`report_id`),
- KEY `FKbquuup9f6nyaxe8lialahh54r` (`requestedBy_id`),
- KEY `FK6ne2n7c1nm3whon604jo98n1k` (`requestingCommunity_id`),
- FULLTEXT KEY `labelIndex` (`verificationLabels`),
- CONSTRAINT `FK6ne2n7c1nm3whon604jo98n1k` FOREIGN KEY (`requestingCommunity_id`) REFERENCES `Community` (`id`),
- CONSTRAINT `FKbquuup9f6nyaxe8lialahh54r` FOREIGN KEY (`requestedBy_id`) REFERENCES `UserEntity` (`id`),
- CONSTRAINT `FKex0gu3dk0loy27kjk1yff261v` FOREIGN KEY (`individual_id`) REFERENCES `Individual` (`id`),
- CONSTRAINT `FKsovu3q3gleeuypsabo0uftw48` FOREIGN KEY (`report_id`) REFERENCES `VerificationReportBase` (`id`),
- CONSTRAINT `FKsq3rb61vbid8ianb65trwpw33` FOREIGN KEY (`assignedTo_id`) REFERENCES `Personnel` (`id`),
- CONSTRAINT `FKt2pm09wy1e7x0ar209iaxl5ov` FOREIGN KEY (`parentCommunity_id`) REFERENCES `Community` (`id`)
- ) ENGINE=InnoDB DEFAULT CHARSET=utf8 (io.debezium.connector.mysql.SnapshotReader:886)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,409] INFO Step 7: releasing global read lock to enable MySQL writes (io.debezium.connector.mysql.SnapshotReader:450)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,413] INFO Step 9: committing transaction (io.debezium.connector.mysql.SnapshotReader:635)
- [2019-05-15 13:27:09,415] INFO Completed snapshot in 00:00:06.365 (io.debezium.connector.mysql.SnapshotReader:701)
- [2019-05-15 13:27:09,510] INFO Transitioning from the snapshot reader to the binlog reader (io.debezium.connector.mysql.ChainedReader:199)
- [2019-05-15 13:27:09,552] INFO GTID set purged on server: (io.debezium.connector.mysql.BinlogReader:326)
- [2019-05-15 13:27:09,552] INFO Attempting to generate a filtered GTID set (io.debezium.connector.mysql.MySqlTaskContext:306)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:27:09,554] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
- [2019-05-15 13:27:09,557] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
- May 15, 2019 1:27:09 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
- INFO: Connected to localhost:3306 at 0ead3b18-5461-11e9-be5a-846e9abad705:1-5 (sid:43, cid:268)
- [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)
- [2019-05-15 13:27:09,568] INFO Creating thread debezium-mysqlconnector-cdc-lav-binlog-client (io.debezium.util.Threads:267)
- [2019-05-15 13:28:02,410] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [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)
- [2019-05-15 13:29:02,432] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [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)
- [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.
- Use 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)
- [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)
- [2019-05-15 13:29:39,715] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:209)
- org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
- at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
- at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
- at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
- at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
- at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
- ... 5 more
- [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)
- [2019-05-15 13:29:40,015] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [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)
- org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
- at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
- at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
- at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table aadhaardb.verificationrequestbasewhose schema isn't known to this connector
- at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
- at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
- ... 5 more
- [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)
- [2019-05-15 13:29:40,016] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:430)
- [2019-05-15 13:29:40,017] INFO ChainedReader: Stopping the binlog reader (io.debezium.connector.mysql.ChainedReader:121)
- [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)
- [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)
- [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)
- [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)
- [2019-05-15 13:29:40,021] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask:465)
- [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)
- [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)
- [2019-05-15 13:30:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [2019-05-15 13:31:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [2019-05-15 13:32:02,466] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [2019-05-15 13:33:02,467] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
- [2019-05-15 13:34:02,469] INFO WorkerSourceTask{id=cdc-lav-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
- [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)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement