[2020-09-10 08:40:21,451] 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=/logs/esbadm/kafka, -Dlog4j.configuration=file:/opt/kafka/apps/bin/../etc/kafka/connect-log4j.properties jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 1.8.0_261, 25.261-b12 jvm.classpath = /opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/rest-authorizer-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-resolver-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/checker-qual-2.5.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/failureaccess-1.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/common-config-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/error_prone_annotations-2.2.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-jaxrs-base-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/commons-compress-1.19.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/audience-annotations-0.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/authorizer-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/confluent-connect-secret-registry-plugin-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/guava-27.1-jre.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/validation-api-2.0.1.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-jndi-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/osgi-resource-locator-1.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-transport-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-handler-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-io-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-annotations-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/avro-1.9.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/swagger-models-1.5.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-container-servlet-core-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-plus-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-media-jaxb-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jakarta.el-3.0.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javassist-3.22.0-CR2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-client-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/hk2-utils-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/websocket-client-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-security-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jose4j-0.6.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/hk2-locator-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-server-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/zkclient-0.11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/bcpg-jdk15on-1.61.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/hk2-api-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jakarta.annotation-api-1.3.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-datatype-jdk8-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/common-utils-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-jmx-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/asm-analysis-7.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/common-metrics-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-xml-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/joda-time-2.7.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/zookeeper-3.5.6.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-transport-native-epoll-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-dataformat-yaml-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/classmate-1.3.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-datatype-joda-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-core-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-codec-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/confluent-serializers-new-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax.websocket-client-api-1.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/bcpkix-jdk15on-1.60.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/aopalliance-repackaged-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/metrics-core-2.2.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-bean-validation-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-hk2-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/swagger-annotations-1.5.22.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/kafka-secret-registry-client-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-buffer-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/zookeeper-jute-3.5.6.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax.annotation-api-1.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/asm-commons-7.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/protobuf-java-3.8.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-common-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-webapp-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/activation-1.1.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/asm-tree-7.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jakarta.el-api-3.0.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-util-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-common-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/confluent-security-plugins-common-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/confluent-licensing-new-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-server-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax-websocket-client-impl-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/commons-lang3-3.2.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/kafka-schema-registry-client-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jaxb-api-2.3.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-module-jaxb-annotations-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jsr305-3.0.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/snakeyaml-1.23.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-jaas-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jackson-jaxrs-json-provider-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax.websocket-api-1.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/kafka-secret-registry-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/rest-utils-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jersey-container-servlet-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jakarta.inject-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/animal-sniffer-annotations-1.17.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/protobuf-java-util-3.8.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/j2objc-annotations-1.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/netty-transport-native-unix-common-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-annotations-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/swagger-core-1.5.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/websocket-common-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/websocket-servlet-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/javax-websocket-server-impl-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jetty-http-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/websocket-api-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/confluent-connect-security-plugin-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/websocket-server-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/bcprov-jdk15on-1.60.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/gson-2.8.5.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/jboss-logging-3.3.2.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/kafka-client-plugins-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/hibernate-validator-6.0.11.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-security/connect/asm-7.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/rest-authorizer-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/cloudevents-kafka-0.3.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/failureaccess-1.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/bc-fips-1.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-jaxrs-base-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/httpclient-4.5.9.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/api-common-1.8.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/commons-compress-1.19.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/audience-annotations-0.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/authorizer-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/ion-java-1.0.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-oauth-client-1.30.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/slf4j-log4j12-1.7.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jbcrypt-0.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/validation-api-2.0.1.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-transforms-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-file-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-io-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-all-4.1.42.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/aws-java-sdk-kms-1.11.475.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/javassist-3.26.0-GA.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-annotations-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/avro-1.9.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/confluent-resource-names-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-container-servlet-core-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/support-metrics-client-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-media-jaxb-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/rocksdbjni-5.18.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-client-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/hk2-utils-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/proto-google-iam-v1-0.12.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/commons-logging-1.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka_2.12-5.4.1-ce-test.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-security-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jose4j-0.6.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/zookeeper-jute-3.5.7.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/bctls-fips-1.0.9.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-api-client-1.30.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/bcpkix-fips-1.0.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/support-metrics-common-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/hibernate-validator-6.0.17.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/opencensus-api-0.21.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/hk2-locator-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-handler-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/commons-codec-1.11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-server-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/zkclient-0.11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/hk2-api-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jakarta.annotation-api-1.3.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/opencensus-contrib-http-util-0.21.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-tcnative-boringssl-static-2.0.26.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-runtime-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-mirror-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-datatype-jdk8-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/grpc-context-1.19.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-cloud-storage-1.82.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/guava-20.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka_2.12-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/zookeeper-3.5.7.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-transport-native-epoll-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-streams-scala_2.12-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/commons-cli-1.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-clients-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/joda-time-2.8.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/guava-28.0-android.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-auth-library-credentials-0.16.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-log4j-appender-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/classmate-1.3.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-streams-test-utils-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-core-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-cloud-core-1.82.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/annotations-3.0.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-module-scala_2.12-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-streams-examples-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-dataformat-csv-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-client-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-resolver-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/confluent-audit-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/aopalliance-repackaged-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-dataformat-cbor-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/scala-library-2.12.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-codec-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/metrics-core-2.2.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/j2objc-annotations-1.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/proto-google-common-protos-1.16.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/scala-java8-compat_2.12-0.9.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/javax.el-3.0.1-b11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-http-client-1.30.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/gax-httpjson-0.64.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-mirror-client-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-hk2-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/checker-compat-qual-2.5.5.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-tools-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/maven-artifact-3.6.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/argparse4j-0.7.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-api-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/protobuf-java-3.8.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/activation-1.1.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/httpcore-4.4.11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-util-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/zstd-jni-1.4.3-1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-cloud-core-http-1.82.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-streams-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-common-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-transport-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-json-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-server-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/scala-reflect-2.12.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jaxb-api-2.3.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-module-jaxb-annotations-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/httpmime-4.5.9.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jsr305-3.0.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-databind-2.9.10.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-jaxrs-json-provider-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/httpclient-4.5.8.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/aws-java-sdk-s3-1.11.475.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/commons-lang3-3.8.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/confluent-metrics-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/threetenbp-1.3.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/javax.annotation-api-1.3.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/scala-logging_2.12-3.9.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-api-services-storage-v1-rev20190624-1.30.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-buffer-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jersey-container-servlet-2.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/connect-basic-auth-extension-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jakarta.inject-2.5.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-transport-native-unix-common-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/animal-sniffer-annotations-1.17.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/aws-java-sdk-core-1.11.475.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/protobuf-java-util-3.8.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/log4j-1.2.17.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-http-client-appengine-1.30.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jmespath-java-1.11.475.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka_2.12-5.4.1-ce-javadoc.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/plexus-utils-3.2.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/netty-common-4.1.45.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/flatbuffers-java-1.9.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-datatype-protobuf-0.9.11-jackson2.9.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/reflections-0.9.11.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-auth-library-oauth2-http-0.16.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/support-metrics-fullcollector-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/gax-1.47.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/auth-providers-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jetty-http-9.4.20.v20190813.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jopt-simple-5.0.4.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/lz4-java-1.6.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/snappy-java-1.1.7.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/rbac-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/paranamer-2.8.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/error_prone_annotations-2.3.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jackson-module-paranamer-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/broker-plugins-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/slf4j-api-1.7.28.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/cloudevents-api-0.3.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/gson-2.8.5.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/google-http-client-jackson2-1.30.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/jboss-logging-3.3.2.Final.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka_2.12-5.4.1-ce-scaladoc.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/kafka-client-plugins-5.4.1-ce.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka/scala-collection-compat_2.12-2.1.2.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-common/build-tools-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-common/common-config-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-common/common-utils-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-common/common-metrics-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/confluent-common/slf4j-api-1.7.26.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/kafka-json-serializer-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/commons-compress-1.19.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/kafka-avro-serializer-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/jackson-annotations-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/avro-1.9.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/swagger-models-1.5.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/guava-20.0.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/joda-time-2.7.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/jackson-dataformat-yaml-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/jackson-datatype-joda-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/jackson-core-2.9.10.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/swagger-annotations-1.5.22.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/kafka-schema-registry-client-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/snakeyaml-1.23.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/jackson-databind-2.9.10.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/commons-lang3-3.8.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/swagger-core-1.5.3.jar:/opt/kafka/bin/confluent-5.4.1/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.4.1.jar:/opt/kafka/bin/confluent-5.4.1/share/java/monitoring-interceptors/monitoring-interceptors-5.4.1.jar:/opt/kafka/apps/bin/../ce-broker-plugins/build/libs/*:/opt/kafka/apps/bin/../ce-broker-plugins/build/dependant-libs/*:/opt/kafka/apps/bin/../ce-auth-providers/build/libs/*:/opt/kafka/apps/bin/../ce-auth-providers/build/dependant-libs/*:/opt/kafka/apps/bin/../ce-rest-server/build/libs/*:/opt/kafka/apps/bin/../ce-rest-server/build/dependant-libs/*:/opt/kafka/apps/bin/../ce-audit/build/libs/*:/opt/kafka/apps/bin/../ce-audit/build/dependant-libs/*:/opt/kafka/apps/bin/../share/java/kafka/rest-authorizer-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/cloudevents-kafka-0.3.1.jar:/opt/kafka/apps/bin/../share/java/kafka/failureaccess-1.0.1.jar:/opt/kafka/apps/bin/../share/java/kafka/bc-fips-1.0.1.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-jaxrs-base-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/httpclient-4.5.9.jar:/opt/kafka/apps/bin/../share/java/kafka/api-common-1.8.1.jar:/opt/kafka/apps/bin/../share/java/kafka/commons-compress-1.19.jar:/opt/kafka/apps/bin/../share/java/kafka/audience-annotations-0.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/authorizer-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/ion-java-1.0.2.jar:/opt/kafka/apps/bin/../share/java/kafka/google-oauth-client-1.30.1.jar:/opt/kafka/apps/bin/../share/java/kafka/slf4j-log4j12-1.7.28.jar:/opt/kafka/apps/bin/../share/java/kafka/jbcrypt-0.4.jar:/opt/kafka/apps/bin/../share/java/kafka/validation-api-2.0.1.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-transforms-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-file-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-io-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-all-4.1.42.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/aws-java-sdk-kms-1.11.475.jar:/opt/kafka/apps/bin/../share/java/kafka/javassist-3.26.0-GA.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-annotations-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/avro-1.9.1.jar:/opt/kafka/apps/bin/../share/java/kafka/confluent-resource-names-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-container-servlet-core-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/support-metrics-client-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-media-jaxb-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/rocksdbjni-5.18.3.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-client-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/hk2-utils-2.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/proto-google-iam-v1-0.12.0.jar:/opt/kafka/apps/bin/../share/java/kafka/commons-logging-1.2.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka_2.12-5.4.1-ce-test.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-security-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/jose4j-0.6.4.jar:/opt/kafka/apps/bin/../share/java/kafka/zookeeper-jute-3.5.7.jar:/opt/kafka/apps/bin/../share/java/kafka/bctls-fips-1.0.9.jar:/opt/kafka/apps/bin/../share/java/kafka/google-api-client-1.30.2.jar:/opt/kafka/apps/bin/../share/java/kafka/bcpkix-fips-1.0.3.jar:/opt/kafka/apps/bin/../share/java/kafka/support-metrics-common-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/hibernate-validator-6.0.17.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/opencensus-api-0.21.0.jar:/opt/kafka/apps/bin/../share/java/kafka/hk2-locator-2.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-handler-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/commons-codec-1.11.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-server-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/zkclient-0.11.jar:/opt/kafka/apps/bin/../share/java/kafka/hk2-api-2.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/jakarta.annotation-api-1.3.4.jar:/opt/kafka/apps/bin/../share/java/kafka/opencensus-contrib-http-util-0.21.0.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-tcnative-boringssl-static-2.0.26.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-runtime-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-mirror-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-datatype-jdk8-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/grpc-context-1.19.0.jar:/opt/kafka/apps/bin/../share/java/kafka/google-cloud-storage-1.82.0.jar:/opt/kafka/apps/bin/../share/java/kafka/guava-20.0.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka_2.12-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/zookeeper-3.5.7.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-transport-native-epoll-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-streams-scala_2.12-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/commons-cli-1.4.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-clients-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/joda-time-2.8.1.jar:/opt/kafka/apps/bin/../share/java/kafka/guava-28.0-android.jar:/opt/kafka/apps/bin/../share/java/kafka/google-auth-library-credentials-0.16.2.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-log4j-appender-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/classmate-1.3.4.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-streams-test-utils-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-core-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/google-cloud-core-1.82.0.jar:/opt/kafka/apps/bin/../share/java/kafka/annotations-3.0.1.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-module-scala_2.12-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-streams-examples-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-dataformat-csv-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-client-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-resolver-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/confluent-audit-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/aopalliance-repackaged-2.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-dataformat-cbor-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/scala-library-2.12.10.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-codec-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/metrics-core-2.2.0.jar:/opt/kafka/apps/bin/../share/java/kafka/j2objc-annotations-1.3.jar:/opt/kafka/apps/bin/../share/java/kafka/proto-google-common-protos-1.16.0.jar:/opt/kafka/apps/bin/../share/java/kafka/scala-java8-compat_2.12-0.9.0.jar:/opt/kafka/apps/bin/../share/java/kafka/javax.el-3.0.1-b11.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/google-http-client-1.30.1.jar:/opt/kafka/apps/bin/../share/java/kafka/gax-httpjson-0.64.1.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-mirror-client-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-hk2-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/apps/bin/../share/java/kafka/checker-compat-qual-2.5.5.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-tools-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/maven-artifact-3.6.1.jar:/opt/kafka/apps/bin/../share/java/kafka/argparse4j-0.7.0.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-api-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/protobuf-java-3.8.0.jar:/opt/kafka/apps/bin/../share/java/kafka/activation-1.1.1.jar:/opt/kafka/apps/bin/../share/java/kafka/httpcore-4.4.11.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-util-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/zstd-jni-1.4.3-1.jar:/opt/kafka/apps/bin/../share/java/kafka/google-cloud-core-http-1.82.0.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-streams-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-common-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-transport-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-json-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-server-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/scala-reflect-2.12.10.jar:/opt/kafka/apps/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/opt/kafka/apps/bin/../share/java/kafka/httpmime-4.5.9.jar:/opt/kafka/apps/bin/../share/java/kafka/jsr305-3.0.2.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-databind-2.9.10.3.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/httpclient-4.5.8.jar:/opt/kafka/apps/bin/../share/java/kafka/aws-java-sdk-s3-1.11.475.jar:/opt/kafka/apps/bin/../share/java/kafka/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/apps/bin/../share/java/kafka/commons-lang3-3.8.1.jar:/opt/kafka/apps/bin/../share/java/kafka/confluent-metrics-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/threetenbp-1.3.3.jar:/opt/kafka/apps/bin/../share/java/kafka/javax.annotation-api-1.3.2.jar:/opt/kafka/apps/bin/../share/java/kafka/javax.ws.rs-api-2.1.1.jar:/opt/kafka/apps/bin/../share/java/kafka/scala-logging_2.12-3.9.2.jar:/opt/kafka/apps/bin/../share/java/kafka/google-api-services-storage-v1-rev20190624-1.30.1.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-buffer-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/jersey-container-servlet-2.28.jar:/opt/kafka/apps/bin/../share/java/kafka/connect-basic-auth-extension-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jakarta.inject-2.5.0.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-transport-native-unix-common-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/animal-sniffer-annotations-1.17.jar:/opt/kafka/apps/bin/../share/java/kafka/aws-java-sdk-core-1.11.475.jar:/opt/kafka/apps/bin/../share/java/kafka/protobuf-java-util-3.8.0.jar:/opt/kafka/apps/bin/../share/java/kafka/log4j-1.2.17.jar:/opt/kafka/apps/bin/../share/java/kafka/google-http-client-appengine-1.30.1.jar:/opt/kafka/apps/bin/../share/java/kafka/jmespath-java-1.11.475.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka_2.12-5.4.1-ce-javadoc.jar:/opt/kafka/apps/bin/../share/java/kafka/plexus-utils-3.2.0.jar:/opt/kafka/apps/bin/../share/java/kafka/netty-common-4.1.45.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/flatbuffers-java-1.9.0.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-datatype-protobuf-0.9.11-jackson2.9.jar:/opt/kafka/apps/bin/../share/java/kafka/reflections-0.9.11.jar:/opt/kafka/apps/bin/../share/java/kafka/google-auth-library-oauth2-http-0.16.2.jar:/opt/kafka/apps/bin/../share/java/kafka/support-metrics-fullcollector-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka.jar:/opt/kafka/apps/bin/../share/java/kafka/gax-1.47.1.jar:/opt/kafka/apps/bin/../share/java/kafka/auth-providers-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/jetty-http-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/opt/kafka/apps/bin/../share/java/kafka/lz4-java-1.6.0.jar:/opt/kafka/apps/bin/../share/java/kafka/snappy-java-1.1.7.3.jar:/opt/kafka/apps/bin/../share/java/kafka/rbac-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/paranamer-2.8.jar:/opt/kafka/apps/bin/../share/java/kafka/error_prone_annotations-2.3.2.jar:/opt/kafka/apps/bin/../share/java/kafka/jackson-module-paranamer-2.9.10.jar:/opt/kafka/apps/bin/../share/java/kafka/broker-plugins-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/slf4j-api-1.7.28.jar:/opt/kafka/apps/bin/../share/java/kafka/cloudevents-api-0.3.1.jar:/opt/kafka/apps/bin/../share/java/kafka/gson-2.8.5.jar:/opt/kafka/apps/bin/../share/java/kafka/google-http-client-jackson2-1.30.1.jar:/opt/kafka/apps/bin/../share/java/kafka/jboss-logging-3.3.2.Final.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka_2.12-5.4.1-ce-scaladoc.jar:/opt/kafka/apps/bin/../share/java/kafka/kafka-client-plugins-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/kafka/scala-collection-compat_2.12-2.1.2.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/rest-authorizer-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/failureaccess-1.0.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/bc-fips-1.0.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/authorizer-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jbcrypt-0.4.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/validation-api-2.0.1.Final.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/osgi-resource-locator-1.0.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/concurrent-trees-2.6.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jersey-media-jaxb-2.28.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jakarta.el-3.0.2.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jersey-client-2.28.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jose4j-0.6.4.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/bctls-fips-1.0.9.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/bcpkix-fips-1.0.3.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jersey-server-2.28.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jakarta.annotation-api-1.3.4.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jackson-datatype-jdk8-2.9.10.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/common-utils-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/kafka-clients-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jetty-proxy-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/guava-28.0-android.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/classmate-1.3.4.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/rbac-api-server-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jetty-client-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/metrics-core-2.2.0.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/j2objc-annotations-1.3.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jersey-bean-validation-2.28.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/checker-compat-qual-2.5.5.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jakarta.el-api-3.0.2.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jetty-util-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/zstd-jni-1.4.3-1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jersey-common-2.28.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/confluent-security-plugins-common-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jsr305-3.0.2.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/commons-lang3-3.8.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/javax.ws.rs-api-2.1.1.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jakarta.inject-2.5.0.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/animal-sniffer-annotations-1.17.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/auth-providers-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/lz4-java-1.6.0.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/snappy-java-1.1.7.3.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/rbac-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/error_prone_annotations-2.3.2.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/gson-2.8.5.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/jboss-logging-3.3.2.Final.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/kafka-client-plugins-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-metadata-service/hibernate-validator-6.0.11.Final.jar:/opt/kafka/apps/bin/../share/java/rest-utils/kafka-clients-5.4.1-ccs.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-jaxrs-base-2.9.10.jar:/opt/kafka/apps/bin/../share/java/rest-utils/validation-api-2.0.1.Final.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-jndi-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/osgi-resource-locator-1.0.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-io-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-annotations-2.9.10.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-container-servlet-core-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-plus-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-media-jaxb-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jakarta.el-3.0.2.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javassist-3.22.0-CR2.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-client-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/hk2-utils-2.5.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/websocket-client-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-security-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/hk2-locator-2.5.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-server-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/hk2-api-2.5.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jakarta.annotation-api-1.3.4.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-jmx-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/asm-analysis-7.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-xml-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/classmate-1.3.4.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-core-2.9.10.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax.websocket-client-api-1.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-client-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/aopalliance-repackaged-2.5.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-bean-validation-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-hk2-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax.annotation-api-1.3.jar:/opt/kafka/apps/bin/../share/java/rest-utils/asm-commons-7.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-webapp-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/activation-1.1.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/asm-tree-7.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jakarta.el-api-3.0.2.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-util-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/zstd-jni-1.4.3-1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-common-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-server-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax-websocket-client-impl-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jaxb-api-2.3.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-module-jaxb-annotations-2.9.10.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax.servlet-api-3.1.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-jaas-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-databind-2.9.10.3.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jackson-jaxrs-json-provider-2.9.10.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax.websocket-api-1.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/rest-utils-5.4.1.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jersey-container-servlet-2.28.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jakarta.inject-2.5.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-annotations-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/websocket-common-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/websocket-servlet-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/javax-websocket-server-impl-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jetty-http-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/lz4-java-1.6.0.jar:/opt/kafka/apps/bin/../share/java/rest-utils/snappy-java-1.1.7.3.jar:/opt/kafka/apps/bin/../share/java/rest-utils/websocket-api-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/websocket-server-9.4.20.v20190813.jar:/opt/kafka/apps/bin/../share/java/rest-utils/jboss-logging-3.3.2.Final.jar:/opt/kafka/apps/bin/../share/java/rest-utils/hibernate-validator-6.0.11.Final.jar:/opt/kafka/apps/bin/../share/java/rest-utils/asm-7.1.jar:/opt/kafka/apps/bin/../share/java/confluent-common/build-tools-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-common/common-config-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-common/common-utils-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-common/common-metrics-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-common/slf4j-api-1.7.26.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/error_prone_annotations-2.1.3.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/common-config-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/confluent-schema-registry-validator-plugin-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/commons-compress-1.19.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/guava-24.0-jre.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/checker-compat-qual-2.0.0.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/kafka-avro-serializer-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jackson-annotations-2.9.10.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/avro-1.9.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/swagger-models-1.5.3.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/animal-sniffer-annotations-1.14.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/common-utils-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/caffeine-2.8.0.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/joda-time-2.7.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/kafka-clients-5.4.1-ce.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jackson-dataformat-yaml-2.9.10.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jackson-datatype-joda-2.9.10.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jackson-core-2.9.10.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/swagger-annotations-1.5.22.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/zstd-jni-1.4.3-1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/commons-lang3-3.2.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/kafka-schema-registry-client-5.4.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/snakeyaml-1.23.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jackson-databind-2.9.10.3.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/j2objc-annotations-1.1.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/jsr305-1.3.9.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/swagger-core-1.5.3.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/checker-qual-2.10.0.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/lz4-java-1.6.0.jar:/opt/kafka/apps/bin/../share/java/confluent-security/schema-validator/snappy-java-1.1.7.3.jar:/opt/kafka/apps/bin/../support-metrics-client/build/dependant-libs-2.12.10/*:/opt/kafka/apps/bin/../support-metrics-client/build/libs/*:/usr/share/java/support-metrics-client/*:/opt/kafka/apps/bin/../support-metrics-fullcollector/build/dependant-libs-2.12.10/*:/opt/kafka/apps/bin/../support-metrics-fullcollector/build/libs/*:/usr/share/java/support-metrics-fullcollector/* os.spec = Linux, amd64, 4.18.0-193.14.3.el8_2.x86_64 os.vcpus = 1 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2020-09-10 08:40:21,477] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90) [2020-09-10 08:40:21,689] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:31,769] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,770] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,771] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,771] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,771] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,771] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,771] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,772] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,773] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,774] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:31,776] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-activemq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:32,912] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-activemq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:32,912] INFO Added plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:32,913] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-control-center (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:39,582] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-control-center/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:39,582] INFO Added plugin 'io.confluent.kafka.secretregistry.client.config.provider.SecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:39,583] INFO Added plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:39,583] INFO Loading plugin from: /opt/kafka/apps/share/java/acl (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:43,225] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/acl/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:43,226] INFO Loading plugin from: /opt/kafka/apps/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:45,787] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:45,788] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-metadata-service (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:47,073] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-metadata-service/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:47,074] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:51,548] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:51,549] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:51,549] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:51,549] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:40:51,550] INFO Loading plugin from: /opt/kafka/apps/share/java/ksql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:54,496] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/ksql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:54,497] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:40:54,888] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:40:54,889] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-security (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:07,540] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-security/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:07,541] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-rest (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:09,933] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-rest/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:09,934] INFO Loading plugin from: /opt/kafka/apps/share/java/monitoring-interceptors (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:10,204] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/monitoring-interceptors/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:10,205] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-kafka-mqtt (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:12,871] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-kafka-mqtt/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:12,871] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:12,900] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:12,900] INFO Loading plugin from: /opt/kafka/apps/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:13,555] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:13,556] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-ibmmq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:14,139] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-ibmmq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:14,140] INFO Added plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:14,140] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:14,361] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:14,361] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:14,361] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:14,371] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-hub-client (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:15,135] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-hub-client/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:15,136] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:15,487] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:15,488] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:15,488] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:17,029] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:17,031] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-replicator (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:21,488] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-replicator/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:21,489] INFO Added plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:21,489] INFO Added plugin 'io.confluent.connect.replicator.util.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:21,490] INFO Loading plugin from: /opt/kafka/apps/share/java/confluent-rebalancer (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:25,278] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/confluent-rebalancer/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:25,279] INFO Loading plugin from: /opt/kafka/apps/share/java/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:25,910] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/java/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:25,910] INFO Added plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:25,911] INFO Loading plugin from: /opt/kafka/apps/share/confluent-hub-components/confluentinc-kafka-connect-http (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:26,553] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/confluent-hub-components/confluentinc-kafka-connect-http/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:26,554] INFO Added plugin 'io.confluent.connect.http.HttpSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:26,554] INFO Loading plugin from: /opt/kafka/apps/share/confluent-hub-components/confluentinc-kafka-connect-sftp (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:32,755] WARN Failed to find version for io.confluent.connect.sftp.SftpSinkConnector and using 'unknown' for version; expecting to find file 'io/confluent/connect/sftp/version.properties' using classloader for io.confluent.connect.sftp.SftpSinkConnector (io.confluent.connect.utils.Version:69) [2020-09-10 08:41:32,760] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/confluent-hub-components/confluentinc-kafka-connect-sftp/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:32,760] INFO Added plugin 'io.confluent.connect.sftp.SftpSchemaLessJsonSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:32,760] INFO Added plugin 'io.confluent.connect.sftp.SftpCsvSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:32,760] INFO Added plugin 'io.confluent.connect.sftp.SftpSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:32,760] INFO Added plugin 'io.confluent.connect.sftp.SftpJsonSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:32,761] INFO Loading plugin from: /opt/kafka/apps/share/confluent-hub-components/debezium-connector-oracle (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:241) [2020-09-10 08:41:34,200] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/apps/share/confluent-hub-components/debezium-connector-oracle/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:34,207] INFO Added plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,207] INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,207] INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,208] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,208] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,208] INFO Added plugin 'io.debezium.transforms.ContentBasedRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,208] INFO Added plugin 'io.debezium.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:34,208] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193) [2020-09-10 08:41:45,917] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264) [2020-09-10 08:41:45,936] INFO Added aliases 'ActiveMQSourceConnector' and 'ActiveMQSource' to plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,937] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,937] INFO Added aliases 'HttpSinkConnector' and 'HttpSink' to plugin 'io.confluent.connect.http.HttpSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,938] INFO Added aliases 'IbmMQSourceConnector' and 'IbmMQSource' to plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,939] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,939] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,939] INFO Added aliases 'JmsSourceConnector' and 'JmsSource' to plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,940] INFO Added aliases 'ReplicatorSourceConnector' and 'ReplicatorSource' to plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,940] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,940] INFO Added aliases 'SftpCsvSourceConnector' and 'SftpCsvSource' to plugin 'io.confluent.connect.sftp.SftpCsvSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,940] INFO Added aliases 'SftpJsonSourceConnector' and 'SftpJsonSource' to plugin 'io.confluent.connect.sftp.SftpJsonSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,941] INFO Added aliases 'SftpSchemaLessJsonSourceConnector' and 'SftpSchemaLessJsonSource' to plugin 'io.confluent.connect.sftp.SftpSchemaLessJsonSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,959] INFO Added aliases 'SftpSinkConnector' and 'SftpSink' to plugin 'io.confluent.connect.sftp.SftpSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,960] INFO Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,960] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,960] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,960] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,961] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,961] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,961] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,961] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,961] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,962] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,963] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,963] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,963] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,963] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,964] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,965] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,965] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,965] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,966] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,967] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,967] INFO Added alias 'ContentBasedRouter' to plugin 'io.debezium.transforms.ContentBasedRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,967] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,967] INFO Added alias 'Filter' to plugin 'io.debezium.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,967] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,968] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,969] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,969] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,969] INFO Added alias 'ConnectSecurityExtension' to plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,969] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:411) [2020-09-10 08:41:45,969] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,969] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:45,969] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:414) [2020-09-10 08:41:46,690] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [orclkafka:19093] client.dns.lookup = default client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = connect-configs confluent.connector.task.status.metrics = false connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = connect-cluster header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class 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 = [/bin/java, /opt/kafka/apps/share/java, /opt/kafka/apps/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 = orclkafka rest.port = 18083 rest.servlet.initializor.classes = [] 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 scheduled.rebalance.max.delay.ms = 300000 security.protocol = ssl send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] 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:347) [2020-09-10 08:41:46,691] 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:368) [2020-09-10 08:41:46,691] 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:368) [2020-09-10 08:41:46,691] 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:368) [2020-09-10 08:41:46,691] 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:368) [2020-09-10 08:41:46,707] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43) [2020-09-10 08:41:46,709] INFO AdminClientConfig values: bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-09-10 08:41:47,647] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,647] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,648] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,668] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,668] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,668] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,668] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,669] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,670] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,670] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,670] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:47,670] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:47,670] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:47,670] INFO Kafka startTimeMs: 1599741707670 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:48,945] INFO Kafka cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.connect.util.ConnectUtils:59) [2020-09-10 08:41:48,987] INFO Logging initialized @94618ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:169) [2020-09-10 08:41:49,146] INFO Added connector for http://orclkafka:18083 (org.apache.kafka.connect.runtime.rest.RestServer:133) [2020-09-10 08:41:49,147] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:205) [2020-09-10 08:41:49,169] INFO jetty-9.4.20.v20190813; built: 2019-08-13T21:28:18.144Z; git: 84700530e645e812b336747464d6fbbf370c9a20; jvm 1.8.0_261-b12 (org.eclipse.jetty.server.Server:359) [2020-09-10 08:41:49,313] INFO Started http_orclkafka18083@4228f269{HTTP/1.1,[http/1.1]}{orclkafka:18083} (org.eclipse.jetty.server.AbstractConnector:293) [2020-09-10 08:41:49,313] INFO Started @94944ms (org.eclipse.jetty.server.Server:399) [2020-09-10 08:41:49,340] INFO Advertised URI: http://orclkafka:18083/ (org.apache.kafka.connect.runtime.rest.RestServer:370) [2020-09-10 08:41:49,340] INFO REST server listening at http://orclkafka:18083/, advertising URL http://orclkafka:18083/ (org.apache.kafka.connect.runtime.rest.RestServer:220) [2020-09-10 08:41:49,340] INFO Advertised URI: http://orclkafka:18083/ (org.apache.kafka.connect.runtime.rest.RestServer:370) [2020-09-10 08:41:49,340] INFO REST admin endpoints at http://orclkafka:18083/ (org.apache.kafka.connect.runtime.rest.RestServer:221) [2020-09-10 08:41:49,340] INFO Advertised URI: http://orclkafka:18083/ (org.apache.kafka.connect.runtime.rest.RestServer:370) [2020-09-10 08:41:49,374] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45) [2020-09-10 08:41:49,396] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:49,397] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:49,397] INFO Kafka startTimeMs: 1599741709396 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:49,649] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-09-10 08:41:49,652] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:347) [2020-09-10 08:41:50,008] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:50,012] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:50,012] INFO Kafka startTimeMs: 1599741710008 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:50,016] INFO Kafka Connect distributed worker initialization took 88539ms (org.apache.kafka.connect.cli.ConnectDistributed:128) [2020-09-10 08:41:50,016] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50) [2020-09-10 08:41:50,023] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:225) [2020-09-10 08:41:50,048] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:275) [2020-09-10 08:41:50,050] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184) [2020-09-10 08:41:50,050] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108) [2020-09-10 08:41:50,050] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-09-10 08:41:50,050] INFO AdminClientConfig values: bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-09-10 08:41:50,153] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:243) [2020-09-10 08:41:50,321] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,360] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,361] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,362] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:50,365] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:50,365] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:50,365] INFO Kafka startTimeMs: 1599741710362 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:50,527] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:333) [2020-09-10 08:41:50,527] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:338) [2020-09-10 08:41:50,528] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:140) [2020-09-10 08:41:50,700] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-09-10 08:41:51,108] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,109] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,110] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,111] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:51,112] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:51,112] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:51,112] INFO Kafka startTimeMs: 1599741711112 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:51,173] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [orclkafka:19093] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-cluster group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = 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 = ssl security.providers = null 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 = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-09-10 08:41:51,281] INFO [Producer clientId=producer-1] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:51,771] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,777] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,777] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,777] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,777] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,778] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:51,779] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:51,779] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:51,779] INFO Kafka startTimeMs: 1599741711779 (org.apache.kafka.common.utils.AppInfoParser:119) Sep 10, 2020 8:41:51 AM 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. Sep 10, 2020 8:41:51 AM 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. Sep 10, 2020 8:41:51 AM 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. Sep 10, 2020 8:41:51 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConfluentV1MetadataResource 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.ConfluentV1MetadataResource will be ignored. Sep 10, 2020 8:41:51 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. [2020-09-10 08:41:51,891] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:52,025] INFO [Consumer clientId=consumer-connect-cluster-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:1123) [2020-09-10 08:41:52,030] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,031] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,031] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,031] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,032] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,033] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,033] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,033] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,033] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:52,435] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-10 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,437] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-8 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,437] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-14 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,437] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-12 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,438] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,438] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,438] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-6 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,439] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,439] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-24 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,439] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-18 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,439] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-16 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,439] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-22 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-20 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-9 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-7 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-13 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-11 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,440] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-5 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-23 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-17 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-15 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-21 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,441] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-19 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:52,467] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-09-10 08:41:52,467] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-09-10 08:41:52,468] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110) [2020-09-10 08:41:52,470] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191) [2020-09-10 08:41:52,471] INFO Starting KafkaBasedLog with topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-09-10 08:41:52,471] INFO AdminClientConfig values: bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-09-10 08:41:52,745] INFO HV000001: Hibernate Validator 6.0.11.Final (org.hibernate.validator.internal.util.Version:21) [2020-09-10 08:41:52,937] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,949] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,950] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,951] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,951] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,951] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,951] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:52,951] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:52,951] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:52,951] INFO Kafka startTimeMs: 1599741712951 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:53,131] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-09-10 08:41:53,691] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,692] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,693] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,694] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,695] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,695] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,695] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,695] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,695] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,696] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,699] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,700] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,700] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,700] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,700] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:53,701] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:53,733] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:53,733] INFO Kafka startTimeMs: 1599741713701 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:53,734] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [orclkafka:19093] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-cluster group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = 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 = ssl security.providers = null 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 = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-09-10 08:41:53,926] INFO [Producer clientId=producer-2] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:54,245] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,288] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,288] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,289] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:54,290] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:54,290] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:54,290] INFO Kafka startTimeMs: 1599741714290 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:54,355] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) Sep 10, 2020 8:41:54 AM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. [2020-09-10 08:41:54,366] INFO Started o.e.j.s.ServletContextHandler@769b0752{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:824) [2020-09-10 08:41:54,366] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:318) [2020-09-10 08:41:54,366] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56) [2020-09-10 08:41:54,422] INFO [Consumer clientId=consumer-connect-cluster-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:1123) [2020-09-10 08:41:54,423] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-statuses-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:54,423] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-statuses-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:54,424] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-statuses-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:54,424] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-statuses-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:54,424] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-statuses-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:54,539] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:54,540] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-3 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:54,540] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-4 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:54,540] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:54,540] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-statuses-2 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:54,771] INFO Finished reading KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-09-10 08:41:54,771] INFO Started KafkaBasedLog for topic connect-statuses (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-09-10 08:41:54,771] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:262) [2020-09-10 08:41:54,771] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:126) [2020-09-10 08:41:54,772] INFO AdminClientConfig values: bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig:347) [2020-09-10 08:41:54,943] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,944] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355) [2020-09-10 08:41:54,945] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:54,945] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:54,945] INFO Kafka startTimeMs: 1599741714945 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:55,049] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [orclkafka:19093] 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 = ssl security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-09-10 08:41:55,196] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,196] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,196] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,196] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,197] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355) [2020-09-10 08:41:55,198] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:55,198] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:55,198] INFO Kafka startTimeMs: 1599741715198 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:55,198] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [orclkafka:19093] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-cluster group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = 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 = ssl security.providers = null 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 = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-09-10 08:41:55,304] INFO [Producer clientId=producer-3] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:55,492] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,506] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'producer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'confluent.license' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'rest.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'consumer.bootstrap.servers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,507] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355) [2020-09-10 08:41:55,508] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:55,508] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:55,508] INFO Kafka startTimeMs: 1599741715508 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:55,562] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:55,625] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123) [2020-09-10 08:41:55,625] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:564) [2020-09-10 08:41:55,698] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting offset for partition connect-configs-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState:381) [2020-09-10 08:41:55,745] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:159) [2020-09-10 08:41:55,745] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:161) [2020-09-10 08:41:55,746] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:267) [2020-09-10 08:41:55,746] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:279) [2020-09-10 08:41:55,785] INFO [Worker clientId=connect-1, groupId=connect-cluster] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:55,786] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator orclkafka:19093 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:756) [2020-09-10 08:41:55,793] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:222) [2020-09-10 08:41:55,793] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533) [2020-09-10 08:41:55,862] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:533) [2020-09-10 08:41:55,910] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation 7 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:484) [2020-09-10 08:41:55,911] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 7 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-09a51745-4930-4bd9-9f66-d46d1f21ee78', leaderUrl='http://orclkafka:18083/', offset=26, connectorIds=[hr-connector], taskIds=[hr-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1542) [2020-09-10 08:41:55,911] WARN [Worker clientId=connect-1, groupId=connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1013) [2020-09-10 08:41:55,911] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset -1 is behind group assignment 26, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1074) [2020-09-10 08:41:56,248] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 26 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1078) [2020-09-10 08:41:56,249] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 26 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1104) [2020-09-10 08:41:56,253] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connector hr-connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1179) [2020-09-10 08:41:56,264] INFO ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-09-10 08:41:56,265] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-09-10 08:41:56,266] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting task hr-connector-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1139) [2020-09-10 08:41:56,266] INFO Creating task hr-connector-0 (org.apache.kafka.connect.runtime.Worker:422) [2020-09-10 08:41:56,265] INFO Creating connector hr-connector of type io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:251) [2020-09-10 08:41:56,281] INFO Instantiated connector hr-connector with version 1.2.0.Final of type class io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker:257) [2020-09-10 08:41:56,280] INFO ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:347) [2020-09-10 08:41:56,283] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-09-10 08:41:56,335] INFO TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.TaskConfig:347) [2020-09-10 08:41:56,335] INFO Instantiated task hr-connector-0 with version 1.2.0.Final of type io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.Worker:437) [2020-09-10 08:41:56,396] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2020-09-10 08:41:56,468] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2020-09-10 08:41:56,472] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2020-09-10 08:41:56,481] INFO Finished creating connector hr-connector (org.apache.kafka.connect.runtime.Worker:276) [2020-09-10 08:41:56,510] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:347) [2020-09-10 08:41:56,510] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector 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 = null name = hr-connector tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347) [2020-09-10 08:41:56,574] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2020-09-10 08:41:56,598] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task hr-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:450) [2020-09-10 08:41:56,598] INFO AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig:179) [2020-09-10 08:41:56,598] INFO KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179) [2020-09-10 08:41:56,598] INFO KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.ssl.truststore.type = JKS schema.reflection = false auto.register.schemas = true basic.auth.credentials.source = URL schema.registry.ssl.keystore.password = [hidden] schema.registry.ssl.provider = schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.truststore.location = specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy schema.registry.url = [https://orclkafka:18085] schema.registry.ssl.keystore.location = schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.key.password = [hidden] schema.registry.ssl.keystore.type = JKS proxy.port = -1 schema.registry.ssl.secure.random.implementation = schema.registry.ssl.cipher.suites = [] max.schemas.per.subject = 1000 schema.registry.ssl.truststore.password = [hidden] basic.auth.user.info = [hidden] proxy.host = schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] schema.registry.ssl.protocol = TLS schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN schema.registry.ssl.keymanager.algorithm = SunX509 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179) [2020-09-10 08:41:56,599] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 (io.confluent.connect.avro.AvroDataConfig:347) [2020-09-10 08:41:56,599] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task hr-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:456) [2020-09-10 08:41:56,599] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task hr-connector-0 using the worker config (org.apache.kafka.connect.runtime.Worker:463) [2020-09-10 08:41:56,606] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:517) [2020-09-10 08:41:56,632] INFO ProducerConfig values: acks = all batch.size = 16384 bootstrap.servers = [SSL://orclkafka:19093] buffer.memory = 33554432 client.dns.lookup = default client.id = connector-producer-hr-connector-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor] 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 = SSL security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = [hidden] ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /opt/kafka/security/kafka.client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /opt/kafka/security/kafka.client.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2020-09-10 08:41:56,874] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:56,874] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:56,874] INFO Kafka startTimeMs: 1599741716874 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:56,930] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1125) [2020-09-10 08:41:57,018] INFO [Producer clientId=connector-producer-hr-connector-0] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:57,056] INFO [Worker clientId=connect-1, groupId=connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1440) [2020-09-10 08:41:57,080] INFO Starting OracleConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:95) [2020-09-10 08:41:57,081] INFO connector.class = io.debezium.connector.oracle.OracleConnector (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.user = c##xstrm (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.dbname = ORCLCDB (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.pdb.name = ORCL (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.history.kafka.bootstrap.servers = orclkafka:19092 (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.history.kafka.topic = schema-changes.hr (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.server.name = orcldb (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.port = 1521 (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO task.class = io.debezium.connector.oracle.OracleConnectorTask (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.hostname = 10.7.7.78 (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.password = ******** (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO name = hr-connector (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,082] INFO database.out.server.name = dbzxout (io.debezium.connector.common.BaseSourceTask:97) [2020-09-10 08:41:57,288] INFO KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=orcldb-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=orclkafka:19092, client.id=orcldb-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:215) [2020-09-10 08:41:57,288] INFO KafkaDatabaseHistory Producer config: {bootstrap.servers=orclkafka:19092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=orcldb-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:216) [2020-09-10 08:41:57,289] INFO Requested thread factory for connector OracleConnector, id = orcldb named = db-history-config-check (io.debezium.util.Threads:270) [2020-09-10 08:41:57,291] INFO ProducerConfig values: acks = 1 batch.size = 32768 bootstrap.servers = [orclkafka:19092] buffer.memory = 1048576 client.dns.lookup = default client.id = orcldb-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 security.providers = null 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:347) [2020-09-10 08:41:57,337] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:57,338] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:57,338] INFO Kafka startTimeMs: 1599741717337 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:57,338] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [orclkafka:19092] check.crcs = true client.dns.lookup = default client.id = orcldb-dbhistory client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = orcldb-dbhistory group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = 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 security.providers = null 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.StringDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig:347) [2020-09-10 08:41:57,345] INFO Kafka version: 5.4.1-ce (org.apache.kafka.common.utils.AppInfoParser:117) [2020-09-10 08:41:57,345] INFO Kafka commitId: 27f41d1c0f80868f (org.apache.kafka.common.utils.AppInfoParser:118) [2020-09-10 08:41:57,345] INFO Kafka startTimeMs: 1599741717345 (org.apache.kafka.common.utils.AppInfoParser:119) [2020-09-10 08:41:57,389] INFO [Consumer clientId=orcldb-dbhistory, groupId=orcldb-dbhistory] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:57,403] INFO [Producer clientId=orcldb-dbhistory] Cluster ID: MasjfB0qTAmW463Q3xDu6A (org.apache.kafka.clients.Metadata:259) [2020-09-10 08:41:57,783] INFO Requested thread factory for connector OracleConnector, id = orcldb named = change-event-source-coordinator (io.debezium.util.Threads:270) [2020-09-10 08:41:57,785] INFO Creating thread debezium-oracleconnector-orcldb-change-event-source-coordinator (io.debezium.util.Threads:287) [2020-09-10 08:41:57,800] INFO WorkerSourceTask{id=hr-connector-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:209) [2020-09-10 08:41:57,803] INFO Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator:89) [2020-09-10 08:41:57,803] INFO Context created (io.debezium.pipeline.ChangeEventSourceCoordinator:92) [2020-09-10 08:42:00,119] INFO Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource:95) [2020-09-10 08:42:00,120] INFO Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource:106) [2020-09-10 08:42:02,689] INFO Snapshot step 3 - Locking captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource:113) [2020-09-10 08:42:03,172] INFO Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource:79) [2020-09-10 08:42:03,181] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31) java.lang.RuntimeException: java.sql.SQLSyntaxErrorException: ORA-01738: missing IN keyword at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:96) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.sql.SQLSyntaxErrorException: ORA-01738: missing IN keyword at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1159) at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1056) at oracle.jdbc.driver.T2CStatement.executeForDescribe(T2CStatement.java:922) at oracle.jdbc.driver.T2CStatement.executeForRows(T2CStatement.java:1165) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1136) at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1754) at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1709) at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:300) at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.lockTablesForSchemaSnapshot(OracleSnapshotChangeEventSource.java:98) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:116) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:63) ... 6 more Caused by: Error : 1738, Position : 33, Sql = LOCK TABLE XDBEXT.SYS_NT#WN#KIMV4+GW9HCB3$Z4T_TH IN EXCLUSIVE MODE, OriginalSql = LOCK TABLE XDBEXT.SYS_NT#WN#KIMV4+GW9HCB3$Z4T_TH IN EXCLUSIVE MODE, Error Msg = ORA-01738: missing IN keyword at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1172) ... 16 more [2020-09-10 08:42:03,198] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:60) [2020-09-10 08:42:03,269] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:42:03,270] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:42:03,270] ERROR WorkerSourceTask{id=hr-connector-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:117) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.RuntimeException: java.sql.SQLSyntaxErrorException: ORA-01738: missing IN keyword at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:96) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: ORA-01738: missing IN keyword at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1159) at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1056) at oracle.jdbc.driver.T2CStatement.executeForDescribe(T2CStatement.java:922) at oracle.jdbc.driver.T2CStatement.executeForRows(T2CStatement.java:1165) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1136) at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1754) at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1709) at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:300) at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.lockTablesForSchemaSnapshot(OracleSnapshotChangeEventSource.java:98) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:116) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:63) ... 6 more Caused by: Error : 1738, Position : 33, Sql = LOCK TABLE XDBEXT.SYS_NT#WN#KIMV4+GW9HCB3$Z4T_TH IN EXCLUSIVE MODE, OriginalSql = LOCK TABLE XDBEXT.SYS_NT#WN#KIMV4+GW9HCB3$Z4T_TH IN EXCLUSIVE MODE, Error Msg = ORA-01738: missing IN keyword at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1172) ... 16 more [2020-09-10 08:42:03,271] ERROR WorkerSourceTask{id=hr-connector-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180) [2020-09-10 08:42:03,271] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:187) [2020-09-10 08:42:03,279] INFO [Producer clientId=orcldb-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-09-10 08:42:03,296] INFO [Producer clientId=connector-producer-hr-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183) [2020-09-10 08:42:56,886] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:42:56,887] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:43:56,888] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:43:56,888] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:44:56,889] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:44:56,890] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:45:56,891] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:45:56,891] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:46:56,892] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:46:56,892] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:47:56,893] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:47:56,894] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:48:56,895] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:48:56,896] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:49:56,897] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:49:56,897] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433) [2020-09-10 08:50:56,898] INFO WorkerSourceTask{id=hr-connector-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:416) [2020-09-10 08:50:56,898] INFO WorkerSourceTask{id=hr-connector-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:433)