===> User uid=1000(appuser) gid=1000(appuser) groups=1000(appuser) ===> Configuring ... ===> Running preflight checks ... ===> Check if Kafka is healthy ... ===> Launching ... ===> Launching kafka-connect ... [2022-05-11 10:22:26,673] INFO WorkerInfo values: jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote=true, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/var/log/kafka, -Dlog4j.configuration=file:/etc/kafka/connect-log4j.properties, -Doracle.jdbc.timezoneAsRegion=false, -Xms512M, -Xmx4G jvm.spec = Azul Systems, Inc., OpenJDK 64-Bit Server VM, 11.0.11, 11.0.11+9-LTS jvm.classpath = /usr/share/java/monitoring-interceptors/monitoring-interceptors-7.0.1.jar:/usr/share/java/confluent-security/connect/jersey-container-servlet-core-2.34.jar:/usr/share/java/confluent-security/connect/jna-platform-5.6.0.jar:/usr/share/java/confluent-security/connect/gax-httpjson-0.77.0.jar:/usr/share/java/confluent-security/connect/handy-uri-templates-2.1.8.jar:/usr/share/java/confluent-security/connect/content-type-2.1.jar:/usr/share/java/confluent-security/connect/commons-logging-1.2.jar:/usr/share/java/confluent-security/connect/jakarta.activation-api-1.2.1.jar:/usr/share/java/confluent-security/connect/kafka-json-schema-serializer-6.2.0.jar:/usr/share/java/confluent-security/connect/netty-codec-socks-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/commons-cli-1.4.jar:/usr/share/java/confluent-security/connect/jackson-annotations-2.10.5.jar:/usr/share/java/confluent-security/connect/wire-runtime-3.6.0.jar:/usr/share/java/confluent-security/connect/jackson-datatype-jdk8-2.10.5.jar:/usr/share/java/confluent-security/connect/jetty-util-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jackson-dataformat-cbor-2.11.4.jar:/usr/share/java/confluent-security/connect/jetty-jaas-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jakarta.ws.rs-api-2.1.6.jar:/usr/share/java/confluent-security/connect/google-api-services-storage-v1-rev20200927-1.30.10.jar:/usr/share/java/confluent-security/connect/grpc-protobuf-0.15.0.jar:/usr/share/java/confluent-security/connect/jackson-datatype-guava-2.10.5.jar:/usr/share/java/confluent-security/connect/javassist-3.25.0-GA.jar:/usr/share/java/confluent-security/connect/asm-tree-9.0.jar:/usr/share/java/confluent-security/connect/json-20201115.jar:/usr/share/java/confluent-security/connect/commons-compress-1.20.jar:/usr/share/java/confluent-security/connect/osgi-resource-locator-1.0.3.jar:/usr/share/java/confluent-security/connect/checker-qual-3.8.0.jar:/usr/share/java/confluent-security/connect/jackson-jaxrs-base-2.10.5.jar:/usr/share/java/confluent-security/connect/error_prone_annotations-2.5.1.jar:/usr/share/java/confluent-security/connect/stax2-api-4.2.1.jar:/usr/share/java/confluent-security/connect/joda-time-2.9.9.jar:/usr/share/java/confluent-security/connect/javax.websocket-client-api-1.0.jar:/usr/share/java/confluent-security/connect/scala-java8-compat_2.13-0.9.1.jar:/usr/share/java/confluent-security/connect/confluent-security-plugins-common-6.2.0.jar:/usr/share/java/confluent-security/connect/javax-websocket-server-impl-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jetty-io-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jackson-datatype-joda-2.10.5.jar:/usr/share/java/confluent-security/connect/google-auth-library-credentials-0.22.0.jar:/usr/share/java/confluent-security/connect/mbknor-jackson-jsonschema_2.13-1.0.39.jar:/usr/share/java/confluent-security/connect/kotlin-reflect-1.3.50.jar:/usr/share/java/confluent-security/connect/asm-commons-9.0.jar:/usr/share/java/confluent-security/connect/paranamer-2.8.jar:/usr/share/java/confluent-security/connect/jackson-datatype-jsr310-2.10.5.jar:/usr/share/java/confluent-security/connect/kotlin-scripting-common-1.3.50.jar:/usr/share/java/confluent-security/connect/kafka_2.13-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/jakarta.inject-2.6.1.jar:/usr/share/java/confluent-security/connect/jcip-annotations-1.0-1.jar:/usr/share/java/confluent-security/connect/kafka-secret-registry-client-6.2.0.jar:/usr/share/java/confluent-security/connect/jackson-module-paranamer-2.10.5.jar:/usr/share/java/confluent-security/connect/jackson-jaxrs-json-provider-2.10.5.jar:/usr/share/java/confluent-security/connect/reactor-netty-http-brave-1.0.6.jar:/usr/share/java/confluent-security/connect/jackson-module-parameter-names-2.10.5.jar:/usr/share/java/confluent-security/connect/javax.servlet-api-3.1.0.jar:/usr/share/java/confluent-security/connect/azure-core-1.16.0.jar:/usr/share/java/confluent-security/connect/brave-instrumentation-http-5.13.3.jar:/usr/share/java/confluent-security/connect/authorizer-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/grpc-protobuf-lite-0.15.0.jar:/usr/share/java/confluent-security/connect/bcpkix-jdk15on-1.68.jar:/usr/share/java/confluent-security/connect/jmespath-java-1.11.784.jar:/usr/share/java/confluent-security/connect/json-smart-2.4.2.jar:/usr/share/java/confluent-security/connect/zookeeper-jute-3.5.9.jar:/usr/share/java/confluent-security/connect/audience-annotations-0.5.0.jar:/usr/share/java/confluent-security/connect/jsr305-3.0.2.jar:/usr/share/java/confluent-security/connect/jakarta.el-api-3.0.3.jar:/usr/share/java/confluent-security/connect/netty-resolver-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/zipkin-reporter-2.16.3.jar:/usr/share/java/confluent-security/connect/kafka-connect-avro-converter-6.2.0.jar:/usr/share/java/confluent-security/connect/netty-transport-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/kotlin-stdlib-jdk7-1.4.10.jar:/usr/share/java/confluent-security/connect/gax-1.60.0.jar:/usr/share/java/confluent-security/connect/opencensus-contrib-http-util-0.24.0.jar:/usr/share/java/confluent-security/connect/grpc-context-1.33.1.jar:/usr/share/java/confluent-security/connect/jackson-dataformat-csv-2.10.5.jar:/usr/share/java/confluent-security/connect/classgraph-4.8.21.jar:/usr/share/java/confluent-security/connect/rest-authorizer-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/kotlin-script-runtime-1.3.50.jar:/usr/share/java/confluent-security/connect/websocket-client-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/kafka-protobuf-types-6.2.0.jar:/usr/share/java/confluent-security/connect/confluent-connect-secret-registry-plugin-6.2.0.jar:/usr/share/java/confluent-security/connect/jersey-container-servlet-2.34.jar:/usr/share/java/confluent-security/connect/okio-2.8.0.jar:/usr/share/java/confluent-security/connect/kafka-schema-serializer-6.2.0.jar:/usr/share/java/confluent-security/connect/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/usr/share/java/confluent-security/connect/jetty-annotations-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/aalto-xml-1.0.0.jar:/usr/share/java/confluent-security/connect/jackson-module-scala_2.13-2.10.5.jar:/usr/share/java/confluent-security/connect/lang-tag-1.5.jar:/usr/share/java/confluent-security/connect/google-http-client-1.38.0.jar:/usr/share/java/confluent-security/connect/wire-schema-3.6.0.jar:/usr/share/java/confluent-security/connect/kafka-raft-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/kafka-json-serializer-6.2.0.jar:/usr/share/java/confluent-security/connect/netty-handler-proxy-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/threetenbp-1.5.0.jar:/usr/share/java/confluent-security/connect/netty-tcnative-boringssl-static-2.0.39.Final.jar:/usr/share/java/confluent-security/connect/jakarta.el-3.0.3.jar:/usr/share/java/confluent-security/connect/javax.ws.rs-api-2.1.1.jar:/usr/share/java/confluent-security/connect/aws-java-sdk-core-1.11.784.jar:/usr/share/java/confluent-security/connect/jakarta.validation-api-2.0.2.jar:/usr/share/java/confluent-security/connect/netty-transport-native-unix-common-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/kafka-protobuf-provider-6.2.0.jar:/usr/share/java/confluent-security/connect/google-cloud-core-http-1.93.10.jar:/usr/share/java/confluent-security/connect/kotlinx-coroutines-core-1.1.1.jar:/usr/share/java/confluent-security/connect/httpcore-4.4.13.jar:/usr/share/java/confluent-security/connect/bcpg-jdk15on-1.68.jar:/usr/share/java/confluent-security/connect/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/share/java/confluent-security/connect/kotlin-scripting-compiler-embeddable-1.3.50.jar:/usr/share/java/confluent-security/connect/internal-rest-server-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/activation-1.1.1.jar:/usr/share/java/confluent-security/connect/msal4j-persistence-extension-1.1.0.jar:/usr/share/java/confluent-security/connect/kafka-protobuf-serializer-6.2.0.jar:/usr/share/java/confluent-security/connect/asm-9.0.jar:/usr/share/java/confluent-security/connect/flatbuffers-java-1.9.0.jar:/usr/share/java/confluent-security/connect/protobuf-java-util-3.11.4.jar:/usr/share/java/confluent-security/connect/google-http-client-appengine-1.38.0.jar:/usr/share/java/confluent-security/connect/KeePassJava2-simple-2.1.4.jar:/usr/share/java/confluent-security/connect/kotlin-stdlib-jdk8-1.4.10.jar:/usr/share/java/confluent-security/connect/core-1.54.0.0.jar:/usr/share/java/confluent-security/connect/jersey-bean-validation-2.34.jar:/usr/share/java/confluent-security/connect/validation-api-2.0.1.Final.jar:/usr/share/java/confluent-security/connect/websocket-servlet-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/google-auth-library-oauth2-http-0.22.0.jar:/usr/share/java/confluent-security/connect/netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar:/usr/share/java/confluent-security/connect/aws-java-sdk-s3-1.11.784.jar:/usr/share/java/confluent-security/connect/oauth2-oidc-sdk-9.4.jar:/usr/share/java/confluent-security/connect/KeePassJava2-2.1.4.jar:/usr/share/java/confluent-security/connect/zipkin-reporter-brave-2.16.3.jar:/usr/share/java/confluent-security/connect/KeePassJava2-kdb-2.1.4.jar:/usr/share/java/confluent-security/connect/guava-30.1.1-jre.jar:/usr/share/java/confluent-security/connect/commons-codec-1.11.jar:/usr/share/java/confluent-security/connect/hk2-locator-2.6.1.jar:/usr/share/java/confluent-security/connect/jetty-xml-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jetty-webapp-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jetty-security-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/websocket-api-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/annotations-13.0.jar:/usr/share/java/confluent-security/connect/grpc-stub-0.15.0.jar:/usr/share/java/confluent-security/connect/googleapis-common-protos-0.0.3.jar:/usr/share/java/confluent-security/connect/jetty-continuation-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/reactive-streams-1.0.3.jar:/usr/share/java/confluent-security/connect/jaxb-api-2.3.0.jar:/usr/share/java/confluent-security/connect/jakarta.xml.bind-api-2.3.2.jar:/usr/share/java/confluent-security/connect/jetty-servlet-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/netty-common-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/classmate-1.3.4.jar:/usr/share/java/confluent-security/connect/kafka-connect-protobuf-converter-6.2.0.jar:/usr/share/java/confluent-security/connect/azure-core-http-netty-1.9.2.jar:/usr/share/java/confluent-security/connect/jetty-jndi-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/j2objc-annotations-1.3.jar:/usr/share/java/confluent-security/connect/google-http-client-jackson2-1.38.0.jar:/usr/share/java/confluent-security/connect/KeePassJava2-dom-2.1.4.jar:/usr/share/java/confluent-security/connect/brave-5.13.3.jar:/usr/share/java/confluent-security/connect/bcprov-jdk15on-1.68.jar:/usr/share/java/confluent-security/connect/confluent-serializers-new-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/kafka-secret-registry-6.2.0.jar:/usr/share/java/confluent-security/connect/kafka-avro-serializer-6.2.0.jar:/usr/share/java/confluent-security/connect/netty-transport-native-kqueue-4.1.63.Final-osx-x86_64.jar:/usr/share/java/confluent-security/connect/google-api-client-1.30.11.jar:/usr/share/java/confluent-security/connect/jersey-server-2.34.jar:/usr/share/java/confluent-security/connect/proto-google-iam-v1-1.0.3.jar:/usr/share/java/confluent-security/connect/websocket-common-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/reactor-netty-1.0.6.jar:/usr/share/java/confluent-security/connect/msal4j-1.10.0.jar:/usr/share/java/confluent-security/connect/scala-logging_2.13-3.9.2.jar:/usr/share/java/confluent-security/connect/grpc-core-0.15.0.jar:/usr/share/java/confluent-security/connect/reactor-netty-core-1.0.6.jar:/usr/share/java/confluent-security/connect/asm-analysis-9.0.jar:/usr/share/java/confluent-security/connect/hk2-api-2.6.1.jar:/usr/share/java/confluent-security/connect/javax.websocket-api-1.0.jar:/usr/share/java/confluent-security/connect/hibernate-validator-6.1.7.Final.jar:/usr/share/java/confluent-security/connect/gson-2.8.6.jar:/usr/share/java/confluent-security/connect/woodstox-core-6.2.1.jar:/usr/share/java/confluent-security/connect/kotlin-scripting-jvm-1.3.50.jar:/usr/share/java/confluent-security/connect/aopalliance-repackaged-2.6.1.jar:/usr/share/java/confluent-security/connect/opencensus-api-0.24.0.jar:/usr/share/java/confluent-security/connect/jersey-common-2.34.jar:/usr/share/java/confluent-security/connect/jackson-module-jaxb-annotations-2.10.5.jar:/usr/share/java/confluent-security/connect/KeePassJava2-jaxb-2.1.4.jar:/usr/share/java/confluent-security/connect/scala-reflect-2.13.5.jar:/usr/share/java/confluent-security/connect/protobuf-java-3.11.4.jar:/usr/share/java/confluent-security/connect/kafka-schema-registry-client-6.2.0.jar:/usr/share/java/confluent-security/connect/jose4j-0.7.2.jar:/usr/share/java/confluent-security/connect/database-2.1.4.jar:/usr/share/java/confluent-security/connect/jackson-dataformat-xml-2.10.5.jar:/usr/share/java/confluent-security/connect/jakarta.annotation-api-1.3.5.jar:/usr/share/java/confluent-security/connect/netty-resolver-dns-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/jopt-simple-5.0.4.jar:/usr/share/java/confluent-security/connect/common-config-6.2.0.jar:/usr/share/java/confluent-security/connect/jetty-util-ajax-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/netty-codec-http2-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/scala-collection-compat_2.13-2.3.0.jar:/usr/share/java/confluent-security/connect/commons-digester-1.8.1.jar:/usr/share/java/confluent-security/connect/commons-collections-3.2.2.jar:/usr/share/java/confluent-security/connect/argparse4j-0.7.0.jar:/usr/share/java/confluent-security/connect/jetty-server-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/kafka-json-schema-provider-6.2.0.jar:/usr/share/java/confluent-security/connect/kafka-connect-avro-data-6.2.0.jar:/usr/share/java/confluent-security/connect/jbcrypt-0.4.jar:/usr/share/java/confluent-security/connect/commons-validator-1.6.jar:/usr/share/java/confluent-security/connect/zipkin-2.23.2.jar:/usr/share/java/confluent-security/connect/netty-handler-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/jna-5.5.0.jar:/usr/share/java/confluent-security/connect/confluent-connect-security-plugin-6.2.0.jar:/usr/share/java/confluent-security/connect/metrics-core-2.2.0.jar:/usr/share/java/confluent-security/connect/azure-identity-1.3.0.jar:/usr/share/java/confluent-security/connect/jetty-plus-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/aws-java-sdk-sts-1.11.784.jar:/usr/share/java/confluent-security/connect/netty-codec-http-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/auto-value-annotations-1.7.4.jar:/usr/share/java/confluent-security/connect/broker-plugins-6.2.0-ce-test.jar:/usr/share/java/confluent-security/connect/scala-library-2.13.5.jar:/usr/share/java/confluent-security/connect/jetty-servlets-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/zookeeper-3.5.9.jar:/usr/share/java/confluent-security/connect/hk2-utils-2.6.1.jar:/usr/share/java/confluent-security/connect/netty-codec-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/swagger-annotations-1.6.2.jar:/usr/share/java/confluent-security/connect/KeePassJava2-kdbx-2.1.4.jar:/usr/share/java/confluent-security/connect/jackson-core-2.10.5.jar:/usr/share/java/confluent-security/connect/avro-1.10.1.jar:/usr/share/java/confluent-security/connect/nimbus-jose-jwt-9.8.1.jar:/usr/share/java/confluent-security/connect/jersey-hk2-2.34.jar:/usr/share/java/confluent-security/connect/failureaccess-1.0.1.jar:/usr/share/java/confluent-security/connect/httpclient-4.5.13.jar:/usr/share/java/confluent-security/connect/kotlin-stdlib-1.4.21.jar:/usr/share/java/confluent-security/connect/jetty-jmx-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/jboss-logging-3.3.2.Final.jar:/usr/share/java/confluent-security/connect/proto-google-common-protos-2.0.1.jar:/usr/share/java/confluent-security/connect/reactor-core-3.4.5.jar:/usr/share/java/confluent-security/connect/jersey-client-2.34.jar:/usr/share/java/confluent-security/connect/netty-all-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/netty-buffer-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/aws-java-sdk-kms-1.11.784.jar:/usr/share/java/confluent-security/connect/rest-utils-6.2.0.jar:/usr/share/java/confluent-security/connect/kafka-metadata-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/ion-java-1.0.2.jar:/usr/share/java/confluent-security/connect/netty-resolver-dns-native-macos-4.1.63.Final-osx-x86_64.jar:/usr/share/java/confluent-security/connect/javax-websocket-client-impl-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/confluent-licensing-new-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/jetty-http-9.4.40.v20210413.jar:/usr/share/java/confluent-security/connect/netty-codec-dns-4.1.63.Final.jar:/usr/share/java/confluent-security/connect/kotlin-stdlib-common-1.4.10.jar:/usr/share/java/confluent-security/connect/kafka-connect-json-schema-converter-6.2.0.jar:/usr/share/java/confluent-security/connect/google-oauth-client-1.31.1.jar:/usr/share/java/confluent-security/connect/google-cloud-core-1.93.10.jar:/usr/share/java/confluent-security/connect/checker-compat-qual-2.5.5.jar:/usr/share/java/confluent-security/connect/kafka-client-plugins-6.2.0-ce.jar:/usr/share/java/confluent-security/connect/org.everit.json.schema-1.12.2.jar:/usr/share/java/confluent-security/connect/common-utils-6.2.0.jar:/usr/share/java/confluent-security/connect/accessors-smart-2.4.2.jar:/usr/share/java/confluent-security/connect/google-cloud-storage-1.113.4.jar:/usr/share/java/confluent-security/connect/reactor-netty-http-1.0.6.jar:/usr/share/java/confluent-security/connect/javax.annotation-api-1.3.2.jar:/usr/share/java/confluent-security/connect/api-common-1.10.1.jar:/usr/share/java/confluent-security/connect/re2j-1.3.jar:/usr/share/java/confluent-security/connect/websocket-server-9.4.40.v20210413.jar:/usr/share/java/kafka/jersey-container-servlet-core-2.34.jar:/usr/share/java/kafka/jna-platform-5.6.0.jar:/usr/share/java/kafka/gax-httpjson-0.77.0.jar:/usr/share/java/kafka/kafka.jar:/usr/share/java/kafka/content-type-2.1.jar:/usr/share/java/kafka/commons-logging-1.2.jar:/usr/share/java/kafka/jakarta.activation-api-1.2.1.jar:/usr/share/java/kafka/netty-codec-socks-4.1.63.Final.jar:/usr/share/java/kafka/confluent-log4j-1.2.17-cp2.jar:/usr/share/java/kafka/commons-cli-1.4.jar:/usr/share/java/kafka/connect-mirror-6.2.0-ce.jar:/usr/share/java/kafka/jackson-annotations-2.10.5.jar:/usr/share/java/kafka/jackson-datatype-jdk8-2.10.5.jar:/usr/share/java/kafka/jackson-dataformat-cbor-2.11.4.jar:/usr/share/java/kafka/jakarta.ws.rs-api-2.1.6.jar:/usr/share/java/kafka/google-api-services-storage-v1-rev20200927-1.30.10.jar:/usr/share/java/kafka/bc-fips-1.0.2.jar:/usr/share/java/kafka/error_prone_annotations-2.3.4.jar:/usr/share/java/kafka/auth-providers-6.2.0-ce.jar:/usr/share/java/kafka/osgi-resource-locator-1.0.3.jar:/usr/share/java/kafka/cloudevents-kafka-2.0.0.jar:/usr/share/java/kafka/jackson-jaxrs-base-2.10.5.jar:/usr/share/java/kafka/jetty-servlet-9.4.39.v20210325.jar:/usr/share/java/kafka/stax2-api-4.2.1.jar:/usr/share/java/kafka/joda-time-2.9.9.jar:/usr/share/java/kafka/scala-java8-compat_2.13-0.9.1.jar:/usr/share/java/kafka/google-auth-library-credentials-0.22.0.jar:/usr/share/java/kafka/cloudevents-json-jackson-2.0.0.jar:/usr/share/java/kafka/jetty-http-9.4.39.v20210325.jar:/usr/share/java/kafka/lz4-java-1.7.1.jar:/usr/share/java/kafka/snappy-java-1.1.8.1.jar:/usr/share/java/kafka/paranamer-2.8.jar:/usr/share/java/kafka/jackson-datatype-jsr310-2.10.5.jar:/usr/share/java/kafka/kafka_2.13-6.2.0-ce.jar:/usr/share/java/kafka/jakarta.inject-2.6.1.jar:/usr/share/java/kafka/jcip-annotations-1.0-1.jar:/usr/share/java/kafka/jackson-module-paranamer-2.10.5.jar:/usr/share/java/kafka/jackson-jaxrs-json-provider-2.10.5.jar:/usr/share/java/kafka/reactor-netty-http-brave-1.0.6.jar:/usr/share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/share/java/kafka/azure-core-1.16.0.jar:/usr/share/java/kafka/brave-instrumentation-http-5.13.3.jar:/usr/share/java/kafka/authorizer-6.2.0-ce.jar:/usr/share/java/kafka/bcpkix-fips-1.0.3.jar:/usr/share/java/kafka/jmespath-java-1.11.784.jar:/usr/share/java/kafka/json-smart-2.4.2.jar:/usr/share/java/kafka/zookeeper-jute-3.5.9.jar:/usr/share/java/kafka/audience-annotations-0.5.0.jar:/usr/share/java/kafka/jsr305-3.0.2.jar:/usr/share/java/kafka/netty-resolver-4.1.63.Final.jar:/usr/share/java/kafka/zipkin-reporter-2.16.3.jar:/usr/share/java/kafka/netty-transport-4.1.63.Final.jar:/usr/share/java/kafka/gax-1.60.0.jar:/usr/share/java/kafka/opencensus-contrib-http-util-0.24.0.jar:/usr/share/java/kafka/annotations-3.0.1.jar:/usr/share/java/kafka/grpc-context-1.33.1.jar:/usr/share/java/kafka/jetty-client-9.4.39.v20210325.jar:/usr/share/java/kafka/rbac-6.2.0-ce.jar:/usr/share/java/kafka/jackson-dataformat-csv-2.10.5.jar:/usr/share/java/kafka/connect-file-6.2.0-ce.jar:/usr/share/java/kafka/rest-authorizer-6.2.0-ce.jar:/usr/share/java/kafka/jersey-container-servlet-2.34.jar:/usr/share/java/kafka/aalto-xml-1.0.0.jar:/usr/share/java/kafka/jackson-module-scala_2.13-2.10.5.jar:/usr/share/java/kafka/lang-tag-1.5.jar:/usr/share/java/kafka/google-http-client-1.38.0.jar:/usr/share/java/kafka/rocksdbjni-5.18.4.jar:/usr/share/java/kafka/kafka-raft-6.2.0-ce.jar:/usr/share/java/kafka/netty-handler-proxy-4.1.63.Final.jar:/usr/share/java/kafka/threetenbp-1.5.0.jar:/usr/share/java/kafka/netty-tcnative-boringssl-static-2.0.39.Final.jar:/usr/share/java/kafka/connect-mirror-client-6.2.0-ce.jar:/usr/share/java/kafka/kafka-streams-examples-6.2.0-ce.jar:/usr/share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/share/java/kafka/aws-java-sdk-core-1.11.784.jar:/usr/share/java/kafka/confluent-audit-6.2.0-ce.jar:/usr/share/java/kafka/jakarta.validation-api-2.0.2.jar:/usr/share/java/kafka/kafka-streams-scala_2.13-6.2.0-ce.jar:/usr/share/java/kafka/netty-transport-native-unix-common-4.1.63.Final.jar:/usr/share/java/kafka/connect-api-6.2.0-ce.jar:/usr/share/java/kafka/google-cloud-core-http-1.93.10.jar:/usr/share/java/kafka/jetty-util-9.4.39.v20210325.jar:/usr/share/java/kafka/httpcore-4.4.13.jar:/usr/share/java/kafka/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/share/java/kafka/jna-5.6.0.jar:/usr/share/java/kafka/woodstox-core-6.2.4.jar:/usr/share/java/kafka/internal-rest-server-6.2.0-ce.jar:/usr/share/java/kafka/activation-1.1.1.jar:/usr/share/java/kafka/msal4j-persistence-extension-1.1.0.jar:/usr/share/java/kafka/slf4j-log4j12-1.7.30.jar:/usr/share/java/kafka/flatbuffers-java-1.9.0.jar:/usr/share/java/kafka/protobuf-java-util-3.11.4.jar:/usr/share/java/kafka/google-http-client-appengine-1.38.0.jar:/usr/share/java/kafka/KeePassJava2-simple-2.1.4.jar:/usr/share/java/kafka/kafka-streams-test-utils-6.2.0-ce.jar:/usr/share/java/kafka/core-1.54.0.0.jar:/usr/share/java/kafka/javassist-3.27.0-GA.jar:/usr/share/java/kafka/telemetry-api-1.703.0.jar:/usr/share/java/kafka/cloudevents-core-2.0.0.jar:/usr/share/java/kafka/plexus-utils-3.2.1.jar:/usr/share/java/kafka/jetty-security-9.4.39.v20210325.jar:/usr/share/java/kafka/google-auth-library-oauth2-http-0.22.0.jar:/usr/share/java/kafka/netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar:/usr/share/java/kafka/aws-java-sdk-s3-1.11.784.jar:/usr/share/java/kafka/jackson-datatype-protobuf-0.9.11-jackson2.9.jar:/usr/share/java/kafka/oauth2-oidc-sdk-9.4.jar:/usr/share/java/kafka/connect-json-6.2.0-ce.jar:/usr/share/java/kafka/KeePassJava2-2.1.4.jar:/usr/share/java/kafka/zipkin-reporter-brave-2.16.3.jar:/usr/share/java/kafka/KeePassJava2-kdb-2.1.4.jar:/usr/share/java/kafka/zstd-jni-1.4.9-1.jar:/usr/share/java/kafka/hk2-locator-2.6.1.jar:/usr/share/java/kafka/kafka_2.13-6.2.0-ce-test.jar:/usr/share/java/kafka/kafka-log4j-appender-6.2.0-ce.jar:/usr/share/java/kafka/slf4j-api-1.7.30.jar:/usr/share/java/kafka/reactive-streams-1.0.3.jar:/usr/share/java/kafka/jaxb-api-2.3.0.jar:/usr/share/java/kafka/jakarta.xml.bind-api-2.3.2.jar:/usr/share/java/kafka/netty-common-4.1.63.Final.jar:/usr/share/java/kafka/commons-math3-3.6.1.jar:/usr/share/java/kafka/bctls-fips-1.0.10.jar:/usr/share/java/kafka/azure-core-http-netty-1.9.2.jar:/usr/share/java/kafka/j2objc-annotations-1.3.jar:/usr/share/java/kafka/kafka-streams-6.2.0-ce.jar:/usr/share/java/kafka/google-http-client-jackson2-1.38.0.jar:/usr/share/java/kafka/annotations-15.0.jar:/usr/share/java/kafka/KeePassJava2-dom-2.1.4.jar:/usr/share/java/kafka/kafka-tools-6.2.0-ce.jar:/usr/share/java/kafka/jackson-dataformat-xml-2.12.2.jar:/usr/share/java/kafka/brave-5.13.3.jar:/usr/share/java/kafka/checker-qual-2.8.1.jar:/usr/share/java/kafka/confluent-serializers-new-6.2.0-ce.jar:/usr/share/java/kafka/netty-transport-native-kqueue-4.1.63.Final-osx-x86_64.jar:/usr/share/java/kafka/google-api-client-1.30.11.jar:/usr/share/java/kafka/jersey-server-2.34.jar:/usr/share/java/kafka/jetty-servlets-9.4.39.v20210325.jar:/usr/share/java/kafka/proto-google-iam-v1-1.0.3.jar:/usr/share/java/kafka/reactor-netty-1.0.6.jar:/usr/share/java/kafka/guava-28.1-jre.jar:/usr/share/java/kafka/msal4j-1.10.0.jar:/usr/share/java/kafka/scala-logging_2.13-3.9.2.jar:/usr/share/java/kafka/kafka_2.13-6.2.0-ce-javadoc.jar:/usr/share/java/kafka/reactor-netty-core-1.0.6.jar:/usr/share/java/kafka/hk2-api-2.6.1.jar:/usr/share/java/kafka/opencensus-proto-0.2.0.jar:/usr/share/java/kafka/confluent-resource-names-6.2.0-ce.jar:/usr/share/java/kafka/gson-2.8.6.jar:/usr/share/java/kafka/aopalliance-repackaged-2.6.1.jar:/usr/share/java/kafka/opencensus-api-0.24.0.jar:/usr/share/java/kafka/jersey-common-2.34.jar:/usr/share/java/kafka/jackson-module-jaxb-annotations-2.10.5.jar:/usr/share/java/kafka/KeePassJava2-jaxb-2.1.4.jar:/usr/share/java/kafka/scala-reflect-2.13.5.jar:/usr/share/java/kafka/protobuf-java-3.11.4.jar:/usr/share/java/kafka/jetty-continuation-9.4.39.v20210325.jar:/usr/share/java/kafka/jose4j-0.7.2.jar:/usr/share/java/kafka/commons-codec-1.14.jar:/usr/share/java/kafka/database-2.1.4.jar:/usr/share/java/kafka/jakarta.annotation-api-1.3.5.jar:/usr/share/java/kafka/jetty-io-9.4.39.v20210325.jar:/usr/share/java/kafka/netty-resolver-dns-4.1.63.Final.jar:/usr/share/java/kafka/jopt-simple-5.0.4.jar:/usr/share/java/kafka/netty-codec-http2-4.1.63.Final.jar:/usr/share/java/kafka/jetty-util-ajax-9.4.39.v20210325.jar:/usr/share/java/kafka/jetty-server-9.4.39.v20210325.jar:/usr/share/java/kafka/scala-collection-compat_2.13-2.3.0.jar:/usr/share/java/kafka/asm-8.0.1.jar:/usr/share/java/kafka/argparse4j-0.7.0.jar:/usr/share/java/kafka/jbcrypt-0.4.jar:/usr/share/java/kafka/animal-sniffer-annotations-1.18.jar:/usr/share/java/kafka/zipkin-2.23.2.jar:/usr/share/java/kafka/netty-handler-4.1.63.Final.jar:/usr/share/java/kafka/maven-artifact-3.8.1.jar:/usr/share/java/kafka/commons-lang3-3.11.jar:/usr/share/java/kafka/metrics-core-2.2.0.jar:/usr/share/java/kafka/azure-identity-1.3.0.jar:/usr/share/java/kafka/jackson-databind-2.10.5.1.jar:/usr/share/java/kafka/aws-java-sdk-sts-1.11.784.jar:/usr/share/java/kafka/connect-basic-auth-extension-6.2.0-ce.jar:/usr/share/java/kafka/netty-codec-http-4.1.63.Final.jar:/usr/share/java/kafka/auto-value-annotations-1.7.4.jar:/usr/share/java/kafka/kafka-clients-6.2.0-ce.jar:/usr/share/java/kafka/scala-library-2.13.5.jar:/usr/share/java/kafka/zookeeper-3.5.9.jar:/usr/share/java/kafka/hk2-utils-2.6.1.jar:/usr/share/java/kafka/netty-transport-native-epoll-4.1.63.Final.jar:/usr/share/java/kafka/reflections-0.9.12.jar:/usr/share/java/kafka/netty-codec-4.1.63.Final.jar:/usr/share/java/kafka/telemetry-events-6.2.0-ce.jar:/usr/share/java/kafka/KeePassJava2-kdbx-2.1.4.jar:/usr/share/java/kafka/jackson-core-2.10.5.jar:/usr/share/java/kafka/nimbus-jose-jwt-9.8.1.jar:/usr/share/java/kafka/jersey-hk2-2.34.jar:/usr/share/java/kafka/failureaccess-1.0.1.jar:/usr/share/java/kafka/httpclient-4.5.13.jar:/usr/share/java/kafka/cloudevents-api-2.0.0.jar:/usr/share/java/kafka/connect-transforms-6.2.0-ce.jar:/usr/share/java/kafka/ce-sbk_2.13-6.2.0-ce.jar:/usr/share/java/kafka/proto-google-common-protos-2.0.1.jar:/usr/share/java/kafka/reactor-core-3.4.5.jar:/usr/share/java/kafka/jersey-client-2.34.jar:/usr/share/java/kafka/netty-all-4.1.63.Final.jar:/usr/share/java/kafka/netty-buffer-4.1.63.Final.jar:/usr/share/java/kafka/aws-java-sdk-kms-1.11.784.jar:/usr/share/java/kafka/kafka-metadata-6.2.0-ce.jar:/usr/share/java/kafka/ion-java-1.0.2.jar:/usr/share/java/kafka/broker-plugins-6.2.0-ce.jar:/usr/share/java/kafka/netty-resolver-dns-native-macos-4.1.63.Final-osx-x86_64.jar:/usr/share/java/kafka/confluent-licensing-new-6.2.0-ce.jar:/usr/share/java/kafka/netty-codec-dns-4.1.63.Final.jar:/usr/share/java/kafka/google-oauth-client-1.31.1.jar:/usr/share/java/kafka/telemetry-client-1.703.0.jar:/usr/share/java/kafka/kafka-shell-6.2.0-ce.jar:/usr/share/java/kafka/google-cloud-core-1.93.10.jar:/usr/share/java/kafka/connect-runtime-6.2.0-ce.jar:/usr/share/java/kafka/checker-compat-qual-2.5.5.jar:/usr/share/java/kafka/kafka-client-plugins-6.2.0-ce.jar:/usr/share/java/kafka/accessors-smart-2.4.2.jar:/usr/share/java/kafka/google-cloud-storage-1.113.4.jar:/usr/share/java/kafka/reactor-netty-http-1.0.6.jar:/usr/share/java/kafka/javax.annotation-api-1.3.2.jar:/usr/share/java/kafka/jline-3.12.1.jar:/usr/share/java/kafka/api-common-1.10.1.jar:/usr/share/java/confluent-common/common-metrics-6.2.0.jar:/usr/share/java/confluent-common/build-tools-6.2.0.jar:/usr/share/java/confluent-common/slf4j-api-1.7.30.jar:/usr/share/java/confluent-common/common-config-6.2.0.jar:/usr/share/java/confluent-common/common-utils-6.2.0.jar:/usr/share/java/kafka-serde-tools/handy-uri-templates-2.1.8.jar:/usr/share/java/kafka-serde-tools/commons-logging-1.2.jar:/usr/share/java/kafka-serde-tools/kafka-json-schema-serializer-6.2.0.jar:/usr/share/java/kafka-serde-tools/jackson-annotations-2.10.5.jar:/usr/share/java/kafka-serde-tools/wire-runtime-3.6.0.jar:/usr/share/java/kafka-serde-tools/jackson-datatype-jdk8-2.10.5.jar:/usr/share/java/kafka-serde-tools/jakarta.ws.rs-api-2.1.6.jar:/usr/share/java/kafka-serde-tools/error_prone_annotations-2.3.4.jar:/usr/share/java/kafka-serde-tools/grpc-protobuf-0.15.0.jar:/usr/share/java/kafka-serde-tools/jackson-datatype-guava-2.10.5.jar:/usr/share/java/kafka-serde-tools/json-20201115.jar:/usr/share/java/kafka-serde-tools/commons-compress-1.20.jar:/usr/share/java/kafka-serde-tools/osgi-resource-locator-1.0.3.jar:/usr/share/java/kafka-serde-tools/checker-qual-3.8.0.jar:/usr/share/java/kafka-serde-tools/joda-time-2.9.9.jar:/usr/share/java/kafka-serde-tools/jackson-datatype-joda-2.10.5.jar:/usr/share/java/kafka-serde-tools/kafka-streams-avro-serde-6.2.0.jar:/usr/share/java/kafka-serde-tools/mbknor-jackson-jsonschema_2.13-1.0.39.jar:/usr/share/java/kafka-serde-tools/kotlin-reflect-1.3.50.jar:/usr/share/java/kafka-serde-tools/kafka-streams-6.2.0-ccs.jar:/usr/share/java/kafka-serde-tools/jackson-datatype-jsr310-2.10.5.jar:/usr/share/java/kafka-serde-tools/kotlin-scripting-common-1.3.50.jar:/usr/share/java/kafka-serde-tools/jakarta.inject-2.6.1.jar:/usr/share/java/kafka-serde-tools/jackson-module-parameter-names-2.10.5.jar:/usr/share/java/kafka-serde-tools/grpc-protobuf-lite-0.15.0.jar:/usr/share/java/kafka-serde-tools/jsr305-3.0.2.jar:/usr/share/java/kafka-serde-tools/kafka-connect-avro-converter-6.2.0.jar:/usr/share/java/kafka-serde-tools/kotlin-stdlib-jdk7-1.4.10.jar:/usr/share/java/kafka-serde-tools/classgraph-4.8.21.jar:/usr/share/java/kafka-serde-tools/kotlin-script-runtime-1.3.50.jar:/usr/share/java/kafka-serde-tools/kafka-protobuf-types-6.2.0.jar:/usr/share/java/kafka-serde-tools/okio-2.8.0.jar:/usr/share/java/kafka-serde-tools/kafka-schema-serializer-6.2.0.jar:/usr/share/java/kafka-serde-tools/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/usr/share/java/kafka-serde-tools/rocksdbjni-5.18.4.jar:/usr/share/java/kafka-serde-tools/wire-schema-3.6.0.jar:/usr/share/java/kafka-serde-tools/kafka-json-serializer-6.2.0.jar:/usr/share/java/kafka-serde-tools/kafka-protobuf-provider-6.2.0.jar:/usr/share/java/kafka-serde-tools/kotlinx-coroutines-core-1.1.1.jar:/usr/share/java/kafka-serde-tools/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/share/java/kafka-serde-tools/kotlin-scripting-compiler-embeddable-1.3.50.jar:/usr/share/java/kafka-serde-tools/kafka-protobuf-serializer-6.2.0.jar:/usr/share/java/kafka-serde-tools/protobuf-java-util-3.11.4.jar:/usr/share/java/kafka-serde-tools/kotlin-stdlib-jdk8-1.4.10.jar:/usr/share/java/kafka-serde-tools/validation-api-2.0.1.Final.jar:/usr/share/java/kafka-serde-tools/kafka-streams-protobuf-serde-6.2.0.jar:/usr/share/java/kafka-serde-tools/guava-30.1.1-jre.jar:/usr/share/java/kafka-serde-tools/annotations-13.0.jar:/usr/share/java/kafka-serde-tools/grpc-stub-0.15.0.jar:/usr/share/java/kafka-serde-tools/slf4j-api-1.7.30.jar:/usr/share/java/kafka-serde-tools/googleapis-common-protos-0.0.3.jar:/usr/share/java/kafka-serde-tools/kafka-connect-protobuf-converter-6.2.0.jar:/usr/share/java/kafka-serde-tools/j2objc-annotations-1.3.jar:/usr/share/java/kafka-serde-tools/kafka-avro-serializer-6.2.0.jar:/usr/share/java/kafka-serde-tools/grpc-core-0.15.0.jar:/usr/share/java/kafka-serde-tools/gson-2.8.6.jar:/usr/share/java/kafka-serde-tools/kotlin-scripting-jvm-1.3.50.jar:/usr/share/java/kafka-serde-tools/jersey-common-2.34.jar:/usr/share/java/kafka-serde-tools/protobuf-java-3.11.4.jar:/usr/share/java/kafka-serde-tools/kafka-schema-registry-client-6.2.0.jar:/usr/share/java/kafka-serde-tools/jakarta.annotation-api-1.3.5.jar:/usr/share/java/kafka-serde-tools/commons-digester-1.8.1.jar:/usr/share/java/kafka-serde-tools/commons-collections-3.2.2.jar:/usr/share/java/kafka-serde-tools/kafka-json-schema-provider-6.2.0.jar:/usr/share/java/kafka-serde-tools/kafka-connect-avro-data-6.2.0.jar:/usr/share/java/kafka-serde-tools/commons-validator-1.6.jar:/usr/share/java/kafka-serde-tools/jackson-databind-2.10.5.1.jar:/usr/share/java/kafka-serde-tools/kafka-streams-json-schema-serde-6.2.0.jar:/usr/share/java/kafka-serde-tools/scala-library-2.13.5.jar:/usr/share/java/kafka-serde-tools/swagger-annotations-1.6.2.jar:/usr/share/java/kafka-serde-tools/jackson-core-2.10.5.jar:/usr/share/java/kafka-serde-tools/avro-1.10.1.jar:/usr/share/java/kafka-serde-tools/failureaccess-1.0.1.jar:/usr/share/java/kafka-serde-tools/kotlin-stdlib-1.4.21.jar:/usr/share/java/kafka-serde-tools/kotlin-stdlib-common-1.4.10.jar:/usr/share/java/kafka-serde-tools/kafka-connect-json-schema-converter-6.2.0.jar:/usr/share/java/kafka-serde-tools/org.everit.json.schema-1.12.2.jar:/usr/share/java/kafka-serde-tools/re2j-1.3.jar:/usr/share/java/monitoring-interceptors/monitoring-interceptors-6.2.0.jar:/usr/bin/../ce-broker-plugins/build/libs/*:/usr/bin/../ce-broker-plugins/build/dependant-libs/*:/usr/bin/../ce-auth-providers/build/libs/*:/usr/bin/../ce-auth-providers/build/dependant-libs/*:/usr/bin/../ce-rest-server/build/libs/*:/usr/bin/../ce-rest-server/build/dependant-libs/*:/usr/bin/../ce-audit/build/libs/*:/usr/bin/../ce-audit/build/dependant-libs/*:/usr/bin/../share/java/kafka/jersey-container-servlet-core-2.34.jar:/usr/bin/../share/java/kafka/jna-platform-5.6.0.jar:/usr/bin/../share/java/kafka/gax-httpjson-0.77.0.jar:/usr/bin/../share/java/kafka/kafka.jar:/usr/bin/../share/java/kafka/content-type-2.1.jar:/usr/bin/../share/java/kafka/commons-logging-1.2.jar:/usr/bin/../share/java/kafka/jakarta.activation-api-1.2.1.jar:/usr/bin/../share/java/kafka/netty-codec-socks-4.1.63.Final.jar:/usr/bin/../share/java/kafka/confluent-log4j-1.2.17-cp2.jar:/usr/bin/../share/java/kafka/commons-cli-1.4.jar:/usr/bin/../share/java/kafka/connect-mirror-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jackson-annotations-2.10.5.jar:/usr/bin/../share/java/kafka/jackson-datatype-jdk8-2.10.5.jar:/usr/bin/../share/java/kafka/jackson-dataformat-cbor-2.11.4.jar:/usr/bin/../share/java/kafka/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/kafka/google-api-services-storage-v1-rev20200927-1.30.10.jar:/usr/bin/../share/java/kafka/bc-fips-1.0.2.jar:/usr/bin/../share/java/kafka/error_prone_annotations-2.3.4.jar:/usr/bin/../share/java/kafka/auth-providers-6.2.0-ce.jar:/usr/bin/../share/java/kafka/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/kafka/cloudevents-kafka-2.0.0.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-base-2.10.5.jar:/usr/bin/../share/java/kafka/jetty-servlet-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/stax2-api-4.2.1.jar:/usr/bin/../share/java/kafka/joda-time-2.9.9.jar:/usr/bin/../share/java/kafka/scala-java8-compat_2.13-0.9.1.jar:/usr/bin/../share/java/kafka/google-auth-library-credentials-0.22.0.jar:/usr/bin/../share/java/kafka/cloudevents-json-jackson-2.0.0.jar:/usr/bin/../share/java/kafka/jetty-http-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/lz4-java-1.7.1.jar:/usr/bin/../share/java/kafka/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/kafka/paranamer-2.8.jar:/usr/bin/../share/java/kafka/jackson-datatype-jsr310-2.10.5.jar:/usr/bin/../share/java/kafka/kafka_2.13-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/kafka/jcip-annotations-1.0-1.jar:/usr/bin/../share/java/kafka/jackson-module-paranamer-2.10.5.jar:/usr/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.10.5.jar:/usr/bin/../share/java/kafka/reactor-netty-http-brave-1.0.6.jar:/usr/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/kafka/azure-core-1.16.0.jar:/usr/bin/../share/java/kafka/brave-instrumentation-http-5.13.3.jar:/usr/bin/../share/java/kafka/authorizer-6.2.0-ce.jar:/usr/bin/../share/java/kafka/bcpkix-fips-1.0.3.jar:/usr/bin/../share/java/kafka/jmespath-java-1.11.784.jar:/usr/bin/../share/java/kafka/json-smart-2.4.2.jar:/usr/bin/../share/java/kafka/zookeeper-jute-3.5.9.jar:/usr/bin/../share/java/kafka/audience-annotations-0.5.0.jar:/usr/bin/../share/java/kafka/jsr305-3.0.2.jar:/usr/bin/../share/java/kafka/netty-resolver-4.1.63.Final.jar:/usr/bin/../share/java/kafka/zipkin-reporter-2.16.3.jar:/usr/bin/../share/java/kafka/netty-transport-4.1.63.Final.jar:/usr/bin/../share/java/kafka/gax-1.60.0.jar:/usr/bin/../share/java/kafka/opencensus-contrib-http-util-0.24.0.jar:/usr/bin/../share/java/kafka/annotations-3.0.1.jar:/usr/bin/../share/java/kafka/grpc-context-1.33.1.jar:/usr/bin/../share/java/kafka/jetty-client-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/rbac-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jackson-dataformat-csv-2.10.5.jar:/usr/bin/../share/java/kafka/connect-file-6.2.0-ce.jar:/usr/bin/../share/java/kafka/rest-authorizer-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jersey-container-servlet-2.34.jar:/usr/bin/../share/java/kafka/aalto-xml-1.0.0.jar:/usr/bin/../share/java/kafka/jackson-module-scala_2.13-2.10.5.jar:/usr/bin/../share/java/kafka/lang-tag-1.5.jar:/usr/bin/../share/java/kafka/google-http-client-1.38.0.jar:/usr/bin/../share/java/kafka/rocksdbjni-5.18.4.jar:/usr/bin/../share/java/kafka/kafka-raft-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-handler-proxy-4.1.63.Final.jar:/usr/bin/../share/java/kafka/threetenbp-1.5.0.jar:/usr/bin/../share/java/kafka/netty-tcnative-boringssl-static-2.0.39.Final.jar:/usr/bin/../share/java/kafka/connect-mirror-client-6.2.0-ce.jar:/usr/bin/../share/java/kafka/kafka-streams-examples-6.2.0-ce.jar:/usr/bin/../share/java/kafka/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/kafka/aws-java-sdk-core-1.11.784.jar:/usr/bin/../share/java/kafka/confluent-audit-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jakarta.validation-api-2.0.2.jar:/usr/bin/../share/java/kafka/kafka-streams-scala_2.13-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-transport-native-unix-common-4.1.63.Final.jar:/usr/bin/../share/java/kafka/connect-api-6.2.0-ce.jar:/usr/bin/../share/java/kafka/google-cloud-core-http-1.93.10.jar:/usr/bin/../share/java/kafka/jetty-util-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/httpcore-4.4.13.jar:/usr/bin/../share/java/kafka/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/kafka/jna-5.6.0.jar:/usr/bin/../share/java/kafka/woodstox-core-6.2.4.jar:/usr/bin/../share/java/kafka/internal-rest-server-6.2.0-ce.jar:/usr/bin/../share/java/kafka/activation-1.1.1.jar:/usr/bin/../share/java/kafka/msal4j-persistence-extension-1.1.0.jar:/usr/bin/../share/java/kafka/slf4j-log4j12-1.7.30.jar:/usr/bin/../share/java/kafka/flatbuffers-java-1.9.0.jar:/usr/bin/../share/java/kafka/protobuf-java-util-3.11.4.jar:/usr/bin/../share/java/kafka/google-http-client-appengine-1.38.0.jar:/usr/bin/../share/java/kafka/KeePassJava2-simple-2.1.4.jar:/usr/bin/../share/java/kafka/kafka-streams-test-utils-6.2.0-ce.jar:/usr/bin/../share/java/kafka/core-1.54.0.0.jar:/usr/bin/../share/java/kafka/javassist-3.27.0-GA.jar:/usr/bin/../share/java/kafka/telemetry-api-1.703.0.jar:/usr/bin/../share/java/kafka/cloudevents-core-2.0.0.jar:/usr/bin/../share/java/kafka/plexus-utils-3.2.1.jar:/usr/bin/../share/java/kafka/jetty-security-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/google-auth-library-oauth2-http-0.22.0.jar:/usr/bin/../share/java/kafka/netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar:/usr/bin/../share/java/kafka/aws-java-sdk-s3-1.11.784.jar:/usr/bin/../share/java/kafka/jackson-datatype-protobuf-0.9.11-jackson2.9.jar:/usr/bin/../share/java/kafka/oauth2-oidc-sdk-9.4.jar:/usr/bin/../share/java/kafka/connect-json-6.2.0-ce.jar:/usr/bin/../share/java/kafka/KeePassJava2-2.1.4.jar:/usr/bin/../share/java/kafka/zipkin-reporter-brave-2.16.3.jar:/usr/bin/../share/java/kafka/KeePassJava2-kdb-2.1.4.jar:/usr/bin/../share/java/kafka/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/kafka/hk2-locator-2.6.1.jar:/usr/bin/../share/java/kafka/kafka_2.13-6.2.0-ce-test.jar:/usr/bin/../share/java/kafka/kafka-log4j-appender-6.2.0-ce.jar:/usr/bin/../share/java/kafka/slf4j-api-1.7.30.jar:/usr/bin/../share/java/kafka/reactive-streams-1.0.3.jar:/usr/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/usr/bin/../share/java/kafka/jakarta.xml.bind-api-2.3.2.jar:/usr/bin/../share/java/kafka/netty-common-4.1.63.Final.jar:/usr/bin/../share/java/kafka/commons-math3-3.6.1.jar:/usr/bin/../share/java/kafka/bctls-fips-1.0.10.jar:/usr/bin/../share/java/kafka/azure-core-http-netty-1.9.2.jar:/usr/bin/../share/java/kafka/j2objc-annotations-1.3.jar:/usr/bin/../share/java/kafka/kafka-streams-6.2.0-ce.jar:/usr/bin/../share/java/kafka/google-http-client-jackson2-1.38.0.jar:/usr/bin/../share/java/kafka/annotations-15.0.jar:/usr/bin/../share/java/kafka/KeePassJava2-dom-2.1.4.jar:/usr/bin/../share/java/kafka/kafka-tools-6.2.0-ce.jar:/usr/bin/../share/java/kafka/jackson-dataformat-xml-2.12.2.jar:/usr/bin/../share/java/kafka/brave-5.13.3.jar:/usr/bin/../share/java/kafka/checker-qual-2.8.1.jar:/usr/bin/../share/java/kafka/confluent-serializers-new-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-transport-native-kqueue-4.1.63.Final-osx-x86_64.jar:/usr/bin/../share/java/kafka/google-api-client-1.30.11.jar:/usr/bin/../share/java/kafka/jersey-server-2.34.jar:/usr/bin/../share/java/kafka/jetty-servlets-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/proto-google-iam-v1-1.0.3.jar:/usr/bin/../share/java/kafka/reactor-netty-1.0.6.jar:/usr/bin/../share/java/kafka/guava-28.1-jre.jar:/usr/bin/../share/java/kafka/msal4j-1.10.0.jar:/usr/bin/../share/java/kafka/scala-logging_2.13-3.9.2.jar:/usr/bin/../share/java/kafka/kafka_2.13-6.2.0-ce-javadoc.jar:/usr/bin/../share/java/kafka/reactor-netty-core-1.0.6.jar:/usr/bin/../share/java/kafka/hk2-api-2.6.1.jar:/usr/bin/../share/java/kafka/opencensus-proto-0.2.0.jar:/usr/bin/../share/java/kafka/confluent-resource-names-6.2.0-ce.jar:/usr/bin/../share/java/kafka/gson-2.8.6.jar:/usr/bin/../share/java/kafka/aopalliance-repackaged-2.6.1.jar:/usr/bin/../share/java/kafka/opencensus-api-0.24.0.jar:/usr/bin/../share/java/kafka/jersey-common-2.34.jar:/usr/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.10.5.jar:/usr/bin/../share/java/kafka/KeePassJava2-jaxb-2.1.4.jar:/usr/bin/../share/java/kafka/scala-reflect-2.13.5.jar:/usr/bin/../share/java/kafka/protobuf-java-3.11.4.jar:/usr/bin/../share/java/kafka/jetty-continuation-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/jose4j-0.7.2.jar:/usr/bin/../share/java/kafka/commons-codec-1.14.jar:/usr/bin/../share/java/kafka/database-2.1.4.jar:/usr/bin/../share/java/kafka/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/kafka/jetty-io-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/netty-resolver-dns-4.1.63.Final.jar:/usr/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/usr/bin/../share/java/kafka/netty-codec-http2-4.1.63.Final.jar:/usr/bin/../share/java/kafka/jetty-util-ajax-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/jetty-server-9.4.39.v20210325.jar:/usr/bin/../share/java/kafka/scala-collection-compat_2.13-2.3.0.jar:/usr/bin/../share/java/kafka/asm-8.0.1.jar:/usr/bin/../share/java/kafka/argparse4j-0.7.0.jar:/usr/bin/../share/java/kafka/jbcrypt-0.4.jar:/usr/bin/../share/java/kafka/animal-sniffer-annotations-1.18.jar:/usr/bin/../share/java/kafka/zipkin-2.23.2.jar:/usr/bin/../share/java/kafka/netty-handler-4.1.63.Final.jar:/usr/bin/../share/java/kafka/maven-artifact-3.8.1.jar:/usr/bin/../share/java/kafka/commons-lang3-3.11.jar:/usr/bin/../share/java/kafka/metrics-core-2.2.0.jar:/usr/bin/../share/java/kafka/azure-identity-1.3.0.jar:/usr/bin/../share/java/kafka/jackson-databind-2.10.5.1.jar:/usr/bin/../share/java/kafka/aws-java-sdk-sts-1.11.784.jar:/usr/bin/../share/java/kafka/connect-basic-auth-extension-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-codec-http-4.1.63.Final.jar:/usr/bin/../share/java/kafka/auto-value-annotations-1.7.4.jar:/usr/bin/../share/java/kafka/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/kafka/scala-library-2.13.5.jar:/usr/bin/../share/java/kafka/zookeeper-3.5.9.jar:/usr/bin/../share/java/kafka/hk2-utils-2.6.1.jar:/usr/bin/../share/java/kafka/netty-transport-native-epoll-4.1.63.Final.jar:/usr/bin/../share/java/kafka/reflections-0.9.12.jar:/usr/bin/../share/java/kafka/netty-codec-4.1.63.Final.jar:/usr/bin/../share/java/kafka/telemetry-events-6.2.0-ce.jar:/usr/bin/../share/java/kafka/KeePassJava2-kdbx-2.1.4.jar:/usr/bin/../share/java/kafka/jackson-core-2.10.5.jar:/usr/bin/../share/java/kafka/nimbus-jose-jwt-9.8.1.jar:/usr/bin/../share/java/kafka/jersey-hk2-2.34.jar:/usr/bin/../share/java/kafka/failureaccess-1.0.1.jar:/usr/bin/../share/java/kafka/httpclient-4.5.13.jar:/usr/bin/../share/java/kafka/cloudevents-api-2.0.0.jar:/usr/bin/../share/java/kafka/connect-transforms-6.2.0-ce.jar:/usr/bin/../share/java/kafka/ce-sbk_2.13-6.2.0-ce.jar:/usr/bin/../share/java/kafka/proto-google-common-protos-2.0.1.jar:/usr/bin/../share/java/kafka/reactor-core-3.4.5.jar:/usr/bin/../share/java/kafka/jersey-client-2.34.jar:/usr/bin/../share/java/kafka/netty-all-4.1.63.Final.jar:/usr/bin/../share/java/kafka/netty-buffer-4.1.63.Final.jar:/usr/bin/../share/java/kafka/aws-java-sdk-kms-1.11.784.jar:/usr/bin/../share/java/kafka/kafka-metadata-6.2.0-ce.jar:/usr/bin/../share/java/kafka/ion-java-1.0.2.jar:/usr/bin/../share/java/kafka/broker-plugins-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-resolver-dns-native-macos-4.1.63.Final-osx-x86_64.jar:/usr/bin/../share/java/kafka/confluent-licensing-new-6.2.0-ce.jar:/usr/bin/../share/java/kafka/netty-codec-dns-4.1.63.Final.jar:/usr/bin/../share/java/kafka/google-oauth-client-1.31.1.jar:/usr/bin/../share/java/kafka/telemetry-client-1.703.0.jar:/usr/bin/../share/java/kafka/kafka-shell-6.2.0-ce.jar:/usr/bin/../share/java/kafka/google-cloud-core-1.93.10.jar:/usr/bin/../share/java/kafka/connect-runtime-6.2.0-ce.jar:/usr/bin/../share/java/kafka/checker-compat-qual-2.5.5.jar:/usr/bin/../share/java/kafka/kafka-client-plugins-6.2.0-ce.jar:/usr/bin/../share/java/kafka/accessors-smart-2.4.2.jar:/usr/bin/../share/java/kafka/google-cloud-storage-1.113.4.jar:/usr/bin/../share/java/kafka/reactor-netty-http-1.0.6.jar:/usr/bin/../share/java/kafka/javax.annotation-api-1.3.2.jar:/usr/bin/../share/java/kafka/jline-3.12.1.jar:/usr/bin/../share/java/kafka/api-common-1.10.1.jar:/usr/bin/../share/java/confluent-metadata-service/confluent-log4j-1.2.17-cp2.jar:/usr/bin/../share/java/confluent-metadata-service/jackson-datatype-jdk8-2.10.5.jar:/usr/bin/../share/java/confluent-metadata-service/jetty-util-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-metadata-service/jul-to-slf4j-1.7.30.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/confluent-metadata-service/bc-fips-1.0.2.jar:/usr/bin/../share/java/confluent-metadata-service/auth-providers-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/rbac-api-server-6.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/confluent-metadata-service/cloudevents-kafka-2.0.0.jar:/usr/bin/../share/java/confluent-metadata-service/confluent-security-plugins-common-6.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/cloudevents-json-jackson-2.0.0.jar:/usr/bin/../share/java/confluent-metadata-service/lz4-java-1.7.1.jar:/usr/bin/../share/java/confluent-metadata-service/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/confluent-metadata-service/jackson-datatype-jsr310-2.10.5.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/confluent-metadata-service/authorizer-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/bcpkix-fips-1.0.3.jar:/usr/bin/../share/java/confluent-metadata-service/concurrent-trees-2.6.1.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.el-api-3.0.3.jar:/usr/bin/../share/java/confluent-metadata-service/annotations-3.0.1.jar:/usr/bin/../share/java/confluent-metadata-service/rbac-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/rest-authorizer-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.el-3.0.3.jar:/usr/bin/../share/java/confluent-metadata-service/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/confluent-metadata-service/confluent-audit-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.validation-api-2.0.2.jar:/usr/bin/../share/java/confluent-metadata-service/commons-lang3-3.8.1.jar:/usr/bin/../share/java/confluent-metadata-service/protobuf-java-util-3.11.4.jar:/usr/bin/../share/java/confluent-metadata-service/telemetry-api-1.703.0.jar:/usr/bin/../share/java/confluent-metadata-service/cloudevents-core-2.0.0.jar:/usr/bin/../share/java/confluent-metadata-service/jersey-bean-validation-2.34.jar:/usr/bin/../share/java/confluent-metadata-service/jackson-datatype-protobuf-0.9.11-jackson2.9.jar:/usr/bin/../share/java/confluent-metadata-service/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/confluent-metadata-service/auto-value-annotations-1.7.2.jar:/usr/bin/../share/java/confluent-metadata-service/jetty-client-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-metadata-service/bctls-fips-1.0.10.jar:/usr/bin/../share/java/confluent-metadata-service/jetty-proxy-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-metadata-service/jersey-server-2.34.jar:/usr/bin/../share/java/confluent-metadata-service/opencensus-proto-0.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/confluent-resource-names-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/gson-2.8.6.jar:/usr/bin/../share/java/confluent-metadata-service/jersey-common-2.34.jar:/usr/bin/../share/java/confluent-metadata-service/protobuf-java-3.11.4.jar:/usr/bin/../share/java/confluent-metadata-service/jose4j-0.7.2.jar:/usr/bin/../share/java/confluent-metadata-service/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/confluent-metadata-service/jbcrypt-0.4.jar:/usr/bin/../share/java/confluent-metadata-service/metrics-core-2.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/ce-kafka-http-server-6.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/telemetry-events-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/jackson-core-2.10.5.jar:/usr/bin/../share/java/confluent-metadata-service/cloudevents-api-2.0.0.jar:/usr/bin/../share/java/confluent-metadata-service/jersey-client-2.34.jar:/usr/bin/../share/java/confluent-metadata-service/telemetry-client-1.703.0.jar:/usr/bin/../share/java/confluent-metadata-service/kafka-client-plugins-6.2.0-ce.jar:/usr/bin/../share/java/confluent-metadata-service/common-utils-6.2.0.jar:/usr/bin/../share/java/confluent-metadata-service/javax.annotation-api-1.3.2.jar:/usr/bin/../share/java/rest-utils/jersey-container-servlet-core-2.34.jar:/usr/bin/../share/java/rest-utils/jakarta.activation-api-1.2.1.jar:/usr/bin/../share/java/rest-utils/kafka-clients-6.2.0-ccs.jar:/usr/bin/../share/java/rest-utils/jackson-annotations-2.10.5.jar:/usr/bin/../share/java/rest-utils/jetty-util-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-jaas-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/rest-utils/javassist-3.25.0-GA.jar:/usr/bin/../share/java/rest-utils/asm-tree-9.0.jar:/usr/bin/../share/java/rest-utils/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/rest-utils/checker-qual-3.8.0.jar:/usr/bin/../share/java/rest-utils/jackson-jaxrs-base-2.10.5.jar:/usr/bin/../share/java/rest-utils/error_prone_annotations-2.5.1.jar:/usr/bin/../share/java/rest-utils/javax.websocket-client-api-1.0.jar:/usr/bin/../share/java/rest-utils/javax-websocket-server-impl-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-io-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/lz4-java-1.7.1.jar:/usr/bin/../share/java/rest-utils/asm-commons-9.0.jar:/usr/bin/../share/java/rest-utils/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/rest-utils/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/rest-utils/jackson-jaxrs-json-provider-2.10.5.jar:/usr/bin/../share/java/rest-utils/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/rest-utils/jsr305-3.0.2.jar:/usr/bin/../share/java/rest-utils/jakarta.el-api-3.0.3.jar:/usr/bin/../share/java/rest-utils/websocket-client-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jersey-container-servlet-2.34.jar:/usr/bin/../share/java/rest-utils/jetty-annotations-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jakarta.el-3.0.3.jar:/usr/bin/../share/java/rest-utils/jakarta.validation-api-2.0.2.jar:/usr/bin/../share/java/rest-utils/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/rest-utils/activation-1.1.1.jar:/usr/bin/../share/java/rest-utils/asm-9.0.jar:/usr/bin/../share/java/rest-utils/jersey-bean-validation-2.34.jar:/usr/bin/../share/java/rest-utils/websocket-servlet-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/rest-utils/guava-30.1.1-jre.jar:/usr/bin/../share/java/rest-utils/hk2-locator-2.6.1.jar:/usr/bin/../share/java/rest-utils/jetty-xml-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-webapp-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-security-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/websocket-api-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-continuation-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jaxb-api-2.3.0.jar:/usr/bin/../share/java/rest-utils/jakarta.xml.bind-api-2.3.2.jar:/usr/bin/../share/java/rest-utils/jetty-client-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-servlet-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/classmate-1.3.4.jar:/usr/bin/../share/java/rest-utils/jetty-jndi-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/j2objc-annotations-1.3.jar:/usr/bin/../share/java/rest-utils/jersey-server-2.34.jar:/usr/bin/../share/java/rest-utils/websocket-common-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/asm-analysis-9.0.jar:/usr/bin/../share/java/rest-utils/hk2-api-2.6.1.jar:/usr/bin/../share/java/rest-utils/javax.websocket-api-1.0.jar:/usr/bin/../share/java/rest-utils/hibernate-validator-6.1.7.Final.jar:/usr/bin/../share/java/rest-utils/aopalliance-repackaged-2.6.1.jar:/usr/bin/../share/java/rest-utils/jersey-common-2.34.jar:/usr/bin/../share/java/rest-utils/jackson-module-jaxb-annotations-2.10.5.jar:/usr/bin/../share/java/rest-utils/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/rest-utils/jetty-util-ajax-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-server-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jackson-databind-2.10.5.1.jar:/usr/bin/../share/java/rest-utils/jetty-plus-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-servlets-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/hk2-utils-2.6.1.jar:/usr/bin/../share/java/rest-utils/jackson-core-2.10.5.jar:/usr/bin/../share/java/rest-utils/jersey-hk2-2.34.jar:/usr/bin/../share/java/rest-utils/failureaccess-1.0.1.jar:/usr/bin/../share/java/rest-utils/jetty-jmx-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jboss-logging-3.3.2.Final.jar:/usr/bin/../share/java/rest-utils/jersey-client-2.34.jar:/usr/bin/../share/java/rest-utils/rest-utils-6.2.0.jar:/usr/bin/../share/java/rest-utils/javax-websocket-client-impl-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/jetty-http-9.4.40.v20210413.jar:/usr/bin/../share/java/rest-utils/javax.annotation-api-1.3.2.jar:/usr/bin/../share/java/rest-utils/websocket-server-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-common/common-metrics-6.2.0.jar:/usr/bin/../share/java/confluent-common/build-tools-6.2.0.jar:/usr/bin/../share/java/confluent-common/slf4j-api-1.7.30.jar:/usr/bin/../share/java/confluent-common/common-config-6.2.0.jar:/usr/bin/../share/java/confluent-common/common-utils-6.2.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-container-servlet-core-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.activation-api-1.2.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-annotations-2.10.5.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-util-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-jaas-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/ce-kafka-http-server/javassist-3.25.0-GA.jar:/usr/bin/../share/java/ce-kafka-http-server/asm-tree-9.0.jar:/usr/bin/../share/java/ce-kafka-http-server/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/ce-kafka-http-server/checker-qual-3.8.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-jaxrs-base-2.10.5.jar:/usr/bin/../share/java/ce-kafka-http-server/error_prone_annotations-2.5.1.jar:/usr/bin/../share/java/ce-kafka-http-server/javax.websocket-client-api-1.0.jar:/usr/bin/../share/java/ce-kafka-http-server/javax-websocket-server-impl-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-io-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/lz4-java-1.7.1.jar:/usr/bin/../share/java/ce-kafka-http-server/asm-commons-9.0.jar:/usr/bin/../share/java/ce-kafka-http-server/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-jaxrs-json-provider-2.10.5.jar:/usr/bin/../share/java/ce-kafka-http-server/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jsr305-3.0.2.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.el-api-3.0.3.jar:/usr/bin/../share/java/ce-kafka-http-server/websocket-client-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-container-servlet-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-annotations-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.el-3.0.3.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.validation-api-2.0.2.jar:/usr/bin/../share/java/ce-kafka-http-server/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/ce-kafka-http-server/activation-1.1.1.jar:/usr/bin/../share/java/ce-kafka-http-server/asm-9.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-bean-validation-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/websocket-servlet-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/ce-kafka-http-server/guava-30.1.1-jre.jar:/usr/bin/../share/java/ce-kafka-http-server/hk2-locator-2.6.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-xml-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-webapp-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-security-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/websocket-api-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/slf4j-api-1.7.30.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-continuation-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jaxb-api-2.3.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.xml.bind-api-2.3.2.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-client-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-servlet-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/classmate-1.3.4.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-jndi-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/j2objc-annotations-1.3.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-server-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/websocket-common-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/asm-analysis-9.0.jar:/usr/bin/../share/java/ce-kafka-http-server/hk2-api-2.6.1.jar:/usr/bin/../share/java/ce-kafka-http-server/javax.websocket-api-1.0.jar:/usr/bin/../share/java/ce-kafka-http-server/hibernate-validator-6.1.7.Final.jar:/usr/bin/../share/java/ce-kafka-http-server/aopalliance-repackaged-2.6.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-common-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-module-jaxb-annotations-2.10.5.jar:/usr/bin/../share/java/ce-kafka-http-server/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-util-ajax-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-server-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-databind-2.10.5.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-plus-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/ce-kafka-http-server/ce-kafka-http-server-6.2.0.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-servlets-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/hk2-utils-2.6.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jackson-core-2.10.5.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-hk2-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/failureaccess-1.0.1.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-jmx-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jboss-logging-3.3.2.Final.jar:/usr/bin/../share/java/ce-kafka-http-server/jersey-client-2.34.jar:/usr/bin/../share/java/ce-kafka-http-server/rest-utils-6.2.0.jar:/usr/bin/../share/java/ce-kafka-http-server/javax-websocket-client-impl-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/jetty-http-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-http-server/common-utils-6.2.0.jar:/usr/bin/../share/java/ce-kafka-http-server/javax.annotation-api-1.3.2.jar:/usr/bin/../share/java/ce-kafka-http-server/websocket-server-9.4.40.v20210413.jar:/usr/bin/../share/java/ce-kafka-rest-servlet/ce-kafka-rest-servlet-6.2.0.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/lz4-java-1.7.1.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/ce-kafka-rest-extensions-6.2.0.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/slf4j-api-1.7.30.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/ce-kafka-rest-extensions/common-utils-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/handy-uri-templates-2.1.8.jar:/usr/bin/../share/java/kafka-rest-lib/commons-logging-1.2.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-json-schema-serializer-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/confluent-log4j-1.2.17-cp2.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-clients-6.2.0-ccs.jar:/usr/bin/../share/java/kafka-rest-lib/commons-cli-1.4.jar:/usr/bin/../share/java/kafka-rest-lib/wire-runtime-3.6.0.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-datatype-jdk8-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/grpc-protobuf-0.15.0.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-datatype-guava-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/json-20201115.jar:/usr/bin/../share/java/kafka-rest-lib/commons-compress-1.20.jar:/usr/bin/../share/java/kafka-rest-lib/checker-qual-3.8.0.jar:/usr/bin/../share/java/kafka-rest-lib/error_prone_annotations-2.5.1.jar:/usr/bin/../share/java/kafka-rest-lib/joda-time-2.9.9.jar:/usr/bin/../share/java/kafka-rest-lib/scala-java8-compat_2.13-0.9.1.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-datatype-joda-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/mbknor-jackson-jsonschema_2.13-1.0.39.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-reflect-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/lz4-java-1.7.1.jar:/usr/bin/../share/java/kafka-rest-lib/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/kafka-rest-lib/paranamer-2.8.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-datatype-jsr310-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-scripting-common-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-module-paranamer-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-module-parameter-names-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/grpc-protobuf-lite-0.15.0.jar:/usr/bin/../share/java/kafka-rest-lib/kotlinx-coroutines-core-common-1.1.1.jar:/usr/bin/../share/java/kafka-rest-lib/zookeeper-jute-3.5.9.jar:/usr/bin/../share/java/kafka-rest-lib/audience-annotations-0.5.0.jar:/usr/bin/../share/java/kafka-rest-lib/jsr305-3.0.2.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-stdlib-jdk7-1.4.10.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-dataformat-csv-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/classgraph-4.8.21.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-script-runtime-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-protobuf-types-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/okio-2.8.0.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-schema-serializer-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-module-scala_2.13-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/wire-schema-3.6.0.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-json-serializer-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-protobuf-provider-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/kotlinx-coroutines-core-1.1.1.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-metadata-6.2.0-ccs.jar:/usr/bin/../share/java/kafka-rest-lib/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-scripting-compiler-embeddable-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-protobuf-serializer-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/protobuf-java-util-3.11.4.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-stdlib-jdk8-1.4.10.jar:/usr/bin/../share/java/kafka-rest-lib/validation-api-2.0.1.Final.jar:/usr/bin/../share/java/kafka-rest-lib/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/kafka-rest-lib/guava-30.1.1-jre.jar:/usr/bin/../share/java/kafka-rest-lib/annotations-13.0.jar:/usr/bin/../share/java/kafka-rest-lib/auto-value-annotations-1.7.2.jar:/usr/bin/../share/java/kafka-rest-lib/grpc-stub-0.15.0.jar:/usr/bin/../share/java/kafka-rest-lib/slf4j-api-1.7.30.jar:/usr/bin/../share/java/kafka-rest-lib/googleapis-common-protos-0.0.3.jar:/usr/bin/../share/java/kafka-rest-lib/j2objc-annotations-1.3.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-avro-serializer-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-stdlib-common-1.4.21.jar:/usr/bin/../share/java/kafka-rest-lib/scala-logging_2.13-3.9.2.jar:/usr/bin/../share/java/kafka-rest-lib/grpc-core-0.15.0.jar:/usr/bin/../share/java/kafka-rest-lib/gson-2.8.6.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-scripting-jvm-1.3.50.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-rest-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/scala-reflect-2.13.5.jar:/usr/bin/../share/java/kafka-rest-lib/protobuf-java-3.11.4.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-schema-registry-client-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/jopt-simple-5.0.4.jar:/usr/bin/../share/java/kafka-rest-lib/common-config-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/scala-collection-compat_2.13-2.3.0.jar:/usr/bin/../share/java/kafka-rest-lib/commons-digester-1.8.1.jar:/usr/bin/../share/java/kafka-rest-lib/commons-collections-3.2.2.jar:/usr/bin/../share/java/kafka-rest-lib/argparse4j-0.7.0.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-json-schema-provider-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/spotbugs-annotations-4.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/commons-validator-1.6.jar:/usr/bin/../share/java/kafka-rest-lib/metrics-core-2.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/scala-library-2.13.5.jar:/usr/bin/../share/java/kafka-rest-lib/zookeeper-3.5.9.jar:/usr/bin/../share/java/kafka-rest-lib/kafka_2.13-6.2.0-ccs.jar:/usr/bin/../share/java/kafka-rest-lib/swagger-annotations-1.6.2.jar:/usr/bin/../share/java/kafka-rest-lib/jackson-core-2.10.5.jar:/usr/bin/../share/java/kafka-rest-lib/avro-1.10.1.jar:/usr/bin/../share/java/kafka-rest-lib/failureaccess-1.0.1.jar:/usr/bin/../share/java/kafka-rest-lib/kotlin-stdlib-1.4.21.jar:/usr/bin/../share/java/kafka-rest-lib/kafka-raft-6.2.0-ccs.jar:/usr/bin/../share/java/kafka-rest-lib/org.everit.json.schema-1.12.2.jar:/usr/bin/../share/java/kafka-rest-lib/common-utils-6.2.0.jar:/usr/bin/../share/java/kafka-rest-lib/re2j-1.3.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-container-servlet-core-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.activation-api-1.2.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-annotations-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-datatype-jdk8-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-util-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/confluent-security/kafka-rest/error_prone_annotations-2.3.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/javassist-3.25.0-GA.jar:/usr/bin/../share/java/confluent-security/kafka-rest/commons-compress-1.20.jar:/usr/bin/../share/java/confluent-security/kafka-rest/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-jaxrs-base-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/confluent-security-plugins-common-6.2.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-io-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/lz4-java-1.7.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-jaxrs-json-provider-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/javax.servlet-api-3.1.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/authorizer-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/bcpkix-jdk15on-1.68.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jsr305-3.0.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-client-9.4.39.v20210325.jar:/usr/bin/../share/java/confluent-security/kafka-rest/rest-authorizer-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-container-servlet-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/javax.ws.rs-api-2.1.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.validation-api-2.0.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/connect-api-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/confluent-security/kafka-rest/commons-lang3-3.8.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/activation-1.1.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/protobuf-java-util-3.11.4.jar:/usr/bin/../share/java/confluent-security/kafka-rest/plexus-utils-3.2.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/connect-json-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/hk2-locator-2.6.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-security-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/kafka-log4j-appender-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-continuation-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jaxb-api-2.3.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.xml.bind-api-2.3.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-servlet-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/j2objc-annotations-1.3.jar:/usr/bin/../share/java/confluent-security/kafka-rest/kafka-tools-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/checker-qual-2.8.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/bcprov-jdk15on-1.68.jar:/usr/bin/../share/java/confluent-security/kafka-rest/confluent-serializers-new-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-server-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/guava-28.1-jre.jar:/usr/bin/../share/java/confluent-security/kafka-rest/hk2-api-2.6.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/gson-2.8.6.jar:/usr/bin/../share/java/confluent-security/kafka-rest/aopalliance-repackaged-2.6.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-common-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-module-jaxb-annotations-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/protobuf-java-3.11.4.jar:/usr/bin/../share/java/confluent-security/kafka-rest/kafka-schema-registry-client-6.2.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jose4j-0.7.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-util-ajax-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/argparse4j-0.7.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-server-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jbcrypt-0.4.jar:/usr/bin/../share/java/confluent-security/kafka-rest/animal-sniffer-annotations-1.18.jar:/usr/bin/../share/java/confluent-security/kafka-rest/maven-artifact-3.8.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/metrics-core-2.2.0.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-databind-2.10.5.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/broker-plugins-6.2.0-ce-test.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-servlets-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/hk2-utils-2.6.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/reflections-0.9.12.jar:/usr/bin/../share/java/confluent-security/kafka-rest/swagger-annotations-1.6.2.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jackson-core-2.10.5.jar:/usr/bin/../share/java/confluent-security/kafka-rest/avro-1.10.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-hk2-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/failureaccess-1.0.1.jar:/usr/bin/../share/java/confluent-security/kafka-rest/connect-transforms-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jersey-client-2.34.jar:/usr/bin/../share/java/confluent-security/kafka-rest/confluent-licensing-new-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/jetty-http-9.4.40.v20210413.jar:/usr/bin/../share/java/confluent-security/kafka-rest/connect-runtime-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/kafka-client-plugins-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/kafka-rest/confluent-kafka-rest-security-plugin-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/handy-uri-templates-2.1.8.jar:/usr/bin/../share/java/confluent-security/schema-validator/commons-logging-1.2.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-annotations-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/wire-runtime-3.6.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-datatype-jdk8-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/jakarta.ws.rs-api-2.1.6.jar:/usr/bin/../share/java/confluent-security/schema-validator/grpc-protobuf-0.15.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-datatype-guava-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/json-20201115.jar:/usr/bin/../share/java/confluent-security/schema-validator/commons-compress-1.20.jar:/usr/bin/../share/java/confluent-security/schema-validator/osgi-resource-locator-1.0.3.jar:/usr/bin/../share/java/confluent-security/schema-validator/checker-qual-3.8.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/error_prone_annotations-2.5.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/joda-time-2.9.9.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-datatype-joda-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/mbknor-jackson-jsonschema_2.13-1.0.39.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-reflect-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/lz4-java-1.7.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/snappy-java-1.1.8.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-datatype-jsr310-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-scripting-common-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/jakarta.inject-2.6.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-module-parameter-names-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/grpc-protobuf-lite-0.15.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/jsr305-3.0.2.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-stdlib-jdk7-1.4.10.jar:/usr/bin/../share/java/confluent-security/schema-validator/classgraph-4.8.21.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-script-runtime-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-protobuf-types-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/okio-2.8.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-schema-serializer-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-scripting-compiler-impl-embeddable-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/wire-schema-3.6.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-protobuf-provider-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlinx-coroutines-core-1.1.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-scripting-compiler-embeddable-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/caffeine-2.8.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/protobuf-java-util-3.11.4.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-stdlib-jdk8-1.4.10.jar:/usr/bin/../share/java/confluent-security/schema-validator/validation-api-2.0.1.Final.jar:/usr/bin/../share/java/confluent-security/schema-validator/zstd-jni-1.4.9-1.jar:/usr/bin/../share/java/confluent-security/schema-validator/guava-30.1.1-jre.jar:/usr/bin/../share/java/confluent-security/schema-validator/annotations-13.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/grpc-stub-0.15.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/googleapis-common-protos-0.0.3.jar:/usr/bin/../share/java/confluent-security/schema-validator/j2objc-annotations-1.3.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-avro-serializer-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-stdlib-common-1.4.21.jar:/usr/bin/../share/java/confluent-security/schema-validator/grpc-core-0.15.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/gson-2.8.6.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-scripting-jvm-1.3.50.jar:/usr/bin/../share/java/confluent-security/schema-validator/jersey-common-2.34.jar:/usr/bin/../share/java/confluent-security/schema-validator/protobuf-java-3.11.4.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-schema-registry-client-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/jakarta.annotation-api-1.3.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/confluent-schema-registry-validator-plugin-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/commons-digester-1.8.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/commons-collections-3.2.2.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-json-schema-provider-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/commons-validator-1.6.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-databind-2.10.5.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/kafka-clients-6.2.0-ce.jar:/usr/bin/../share/java/confluent-security/schema-validator/scala-library-2.13.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/swagger-annotations-1.6.2.jar:/usr/bin/../share/java/confluent-security/schema-validator/jackson-core-2.10.5.jar:/usr/bin/../share/java/confluent-security/schema-validator/avro-1.10.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/failureaccess-1.0.1.jar:/usr/bin/../share/java/confluent-security/schema-validator/kotlin-stdlib-1.4.21.jar:/usr/bin/../share/java/confluent-security/schema-validator/org.everit.json.schema-1.12.2.jar:/usr/bin/../share/java/confluent-security/schema-validator/common-utils-6.2.0.jar:/usr/bin/../share/java/confluent-security/schema-validator/re2j-1.3.jar:/usr/bin/../support-metrics-client/build/dependant-libs-2.13.5/*:/usr/bin/../support-metrics-client/build/libs/*:/usr/bin/../share/java/confluent-telemetry/confluent-metrics-6.2.0-ce.jar:/usr/share/java/support-metrics-client/* os.spec = Linux, amd64, 3.10.0-1127.10.1.el7.x86_64 os.vcpus = 8 (org.apache.kafka.connect.runtime.WorkerInfo) [2022-05-11 10:22:26,682] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed) [2022-05-11 10:22:26,711] INFO Loading plugin from: /usr/share/java/confluent-control-center (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-control-center/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'io.confluent.connect.json.JsonSchemaConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,711] INFO Added plugin 'io.confluent.connect.protobuf.ProtobufConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,712] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'io.confluent.kafka.secretregistry.client.config.provider.SecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,713] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:30,718] INFO Loading plugin from: /usr/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,927] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,928] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,929] INFO Loading plugin from: /usr/share/java/kafka-rest-bin (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,937] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-rest-bin/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:32,938] INFO Loading plugin from: /usr/share/java/confluent-metadata-service (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:33,816] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-metadata-service/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:33,817] INFO Loading plugin from: /usr/share/java/ce-kafka-http-server (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:34,318] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ce-kafka-http-server/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:34,319] INFO Loading plugin from: /usr/share/java/ce-kafka-rest-servlet (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:34,325] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ce-kafka-rest-servlet/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:34,326] INFO Loading plugin from: /usr/share/java/confluent-rebalancer (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:35,735] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-rebalancer/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:35,737] INFO Loading plugin from: /usr/share/java/confluent-hub-client (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:36,001] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-hub-client/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:36,003] INFO Loading plugin from: /usr/share/java/ce-kafka-rest-extensions (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:36,350] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/ce-kafka-rest-extensions/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:36,352] INFO Loading plugin from: /usr/share/java/confluent-security (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:41,199] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-security/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:41,200] INFO Loading plugin from: /usr/share/java/acl (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:47,338] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/acl/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:47,339] INFO Loading plugin from: /usr/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:48,205] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:48,206] INFO Loading plugin from: /usr/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:48,216] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:48,216] INFO Loading plugin from: /usr/share/java/confluent-telemetry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:49,012] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/confluent-telemetry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:49,013] INFO Loading plugin from: /usr/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:49,416] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:49,416] INFO Loading plugin from: /usr/share/java/kafka-rest-lib (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,138] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-rest-lib/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,138] INFO Loading plugin from: /usr/share/java/cp-base-new (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,611] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/cp-base-new/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,612] INFO Loading plugin from: /usr/share/java/monitoring-interceptors (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,896] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/monitoring-interceptors/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:50,897] INFO Loading plugin from: /usr/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,373] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,374] INFO Loading plugin from: /usr/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,597] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,678] INFO Loading plugin from: /usr/share/confluent-hub-components/confluentinc-kafka-connect-datagen (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,948] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/confluentinc-kafka-connect-datagen/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,948] INFO Added plugin 'io.confluent.kafka.connect.datagen.DatagenConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:51,949] INFO Loading plugin from: /usr/share/confluent-hub-components/debezium-connector-oracle (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,655] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/debezium-connector-oracle/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,655] INFO Added plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,655] INFO Added plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,655] INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,656] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,656] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,656] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,656] INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,721] INFO Loading plugin from: /usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/jcustenborder-kafka-connect-transform-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.HeaderToField' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.BytesToString$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ToJSON$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.PatternFilter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ToLong$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.BytesToString$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ExtractTimestamp$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.TopicNameToField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ChangeCase$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.PatternFilter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.PatternRename$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,938] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ExtractNestedField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.TopicNameToField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.TimestampNow' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SchemaNameToTopic$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.NormalizeSchema$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ToLong$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.PatternRename$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetNull$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ExtractNestedField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ChangeCase$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.NormalizeSchema$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ExtractTimestamp$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,939] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetNull$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,940] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.ToJSON$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,940] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.TimestampNowField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,940] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.SchemaNameToTopic$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,940] INFO Added plugin 'com.github.jcustenborder.kafka.connect.transform.common.TimestampNowField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:52,941] INFO Loading plugin from: /usr/share/confluent-hub-components/confluentinc-kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,264] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/confluentinc-kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,265] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,265] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,333] INFO Loading plugin from: /usr/share/confluent-hub-components/debezium-connector-sqlserver (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,517] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/confluent-hub-components/debezium-connector-sqlserver/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:53,517] INFO Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,263] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@9e89d68 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,264] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,264] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,264] INFO Added aliases 'DatagenConnector' and 'Datagen' to plugin 'io.confluent.kafka.connect.datagen.DatagenConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,264] INFO Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,264] INFO Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,265] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'JsonSchemaConverter' and 'JsonSchema' to plugin 'io.confluent.connect.json.JsonSchemaConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'ProtobufConverter' and 'Protobuf' to plugin 'io.confluent.connect.protobuf.ProtobufConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,266] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,267] INFO Added alias 'ChangeTopicCase' to plugin 'com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'HeaderToField' to plugin 'com.github.jcustenborder.kafka.connect.transform.common.HeaderToField' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'SetMaximumPrecision' to plugin 'com.github.jcustenborder.kafka.connect.transform.common.SetMaximumPrecision' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'TimestampNow' to plugin 'com.github.jcustenborder.kafka.connect.transform.common.TimestampNow' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,268] INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'ConnectSecurityExtension' to plugin 'io.confluent.connect.security.ConnectSecurityExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,269] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [2022-05-11 10:22:59,347] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = docker-connect-configs confluent.connector.task.status.metrics = false confluent.license = [hidden] confluent.license.inject.into.connectors = true confluent.topic = _confluent-command confluent.topic.bootstrap.servers = [] confluent.topic.client.dns.lookup = use_all_dns_ips confluent.topic.client.id = confluent.topic.connections.max.idle.ms = 540000 confluent.topic.consumer.allow.auto.create.topics = true confluent.topic.consumer.auto.commit.interval.ms = 5000 confluent.topic.consumer.auto.offset.reset = latest confluent.topic.consumer.check.crcs = true confluent.topic.consumer.client.dns.lookup = use_all_dns_ips confluent.topic.consumer.client.id = confluent.topic.consumer.client.rack = confluent.topic.consumer.connections.max.idle.ms = 540000 confluent.topic.consumer.default.api.timeout.ms = 60000 confluent.topic.consumer.enable.auto.commit = true confluent.topic.consumer.exclude.internal.topics = true confluent.topic.consumer.fetch.max.bytes = 52428800 confluent.topic.consumer.fetch.max.wait.ms = 500 confluent.topic.consumer.fetch.min.bytes = 1 confluent.topic.consumer.group.id = null confluent.topic.consumer.group.instance.id = null confluent.topic.consumer.heartbeat.interval.ms = 3000 confluent.topic.consumer.interceptor.classes = [] confluent.topic.consumer.internal.leave.group.on.close = true confluent.topic.consumer.internal.throw.on.fetch.stable.offset.unsupported = false confluent.topic.consumer.isolation.level = read_uncommitted confluent.topic.consumer.max.partition.fetch.bytes = 1048576 confluent.topic.consumer.max.poll.interval.ms = 300000 confluent.topic.consumer.max.poll.records = 500 confluent.topic.consumer.metadata.max.age.ms = 300000 confluent.topic.consumer.metric.reporters = [] confluent.topic.consumer.metrics.num.samples = 2 confluent.topic.consumer.metrics.recording.level = INFO confluent.topic.consumer.metrics.sample.window.ms = 30000 confluent.topic.consumer.partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] confluent.topic.consumer.receive.buffer.bytes = 65536 confluent.topic.consumer.reconnect.backoff.max.ms = 1000 confluent.topic.consumer.reconnect.backoff.ms = 50 confluent.topic.consumer.request.timeout.ms = 30000 confluent.topic.consumer.retry.backoff.ms = 100 confluent.topic.consumer.sasl.client.callback.handler.class = null confluent.topic.consumer.sasl.jaas.config = null confluent.topic.consumer.sasl.kerberos.kinit.cmd = /usr/bin/kinit confluent.topic.consumer.sasl.kerberos.min.time.before.relogin = 60000 confluent.topic.consumer.sasl.kerberos.service.name = null confluent.topic.consumer.sasl.kerberos.ticket.renew.jitter = 0.05 confluent.topic.consumer.sasl.kerberos.ticket.renew.window.factor = 0.8 confluent.topic.consumer.sasl.login.callback.handler.class = null confluent.topic.consumer.sasl.login.class = null confluent.topic.consumer.sasl.login.refresh.buffer.seconds = 300 confluent.topic.consumer.sasl.login.refresh.min.period.seconds = 60 confluent.topic.consumer.sasl.login.refresh.window.factor = 0.8 confluent.topic.consumer.sasl.login.refresh.window.jitter = 0.05 confluent.topic.consumer.sasl.mechanism = GSSAPI confluent.topic.consumer.security.protocol = PLAINTEXT confluent.topic.consumer.security.providers = null confluent.topic.consumer.send.buffer.bytes = 131072 confluent.topic.consumer.session.timeout.ms = 10000 confluent.topic.consumer.socket.connection.setup.timeout.max.ms = 30000 confluent.topic.consumer.socket.connection.setup.timeout.ms = 10000 confluent.topic.consumer.ssl.cipher.suites = null confluent.topic.consumer.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] confluent.topic.consumer.ssl.endpoint.identification.algorithm = https confluent.topic.consumer.ssl.engine.factory.class = null confluent.topic.consumer.ssl.key.password = null confluent.topic.consumer.ssl.keymanager.algorithm = SunX509 confluent.topic.consumer.ssl.keystore.certificate.chain = null confluent.topic.consumer.ssl.keystore.key = null confluent.topic.consumer.ssl.keystore.location = null confluent.topic.consumer.ssl.keystore.password = null confluent.topic.consumer.ssl.keystore.type = JKS confluent.topic.consumer.ssl.protocol = TLSv1.3 confluent.topic.consumer.ssl.provider = null confluent.topic.consumer.ssl.secure.random.implementation = null confluent.topic.consumer.ssl.trustmanager.algorithm = PKIX confluent.topic.consumer.ssl.truststore.certificates = null confluent.topic.consumer.ssl.truststore.location = null confluent.topic.consumer.ssl.truststore.password = null confluent.topic.consumer.ssl.truststore.type = JKS confluent.topic.interceptor.classes = [] confluent.topic.metadata.max.age.ms = 300000 confluent.topic.metric.reporters = [] confluent.topic.metrics.num.samples = 2 confluent.topic.metrics.recording.level = INFO confluent.topic.metrics.sample.window.ms = 30000 confluent.topic.producer.acks = 1 confluent.topic.producer.batch.size = 16384 confluent.topic.producer.buffer.memory = 33554432 confluent.topic.producer.client.dns.lookup = use_all_dns_ips confluent.topic.producer.client.id = confluent.topic.producer.compression.type = none confluent.topic.producer.connections.max.idle.ms = 540000 confluent.topic.producer.delivery.timeout.ms = 120000 confluent.topic.producer.enable.idempotence = false confluent.topic.producer.interceptor.classes = [] confluent.topic.producer.internal.auto.downgrade.txn.commit = false confluent.topic.producer.linger.ms = 0 confluent.topic.producer.max.block.ms = 60000 confluent.topic.producer.max.in.flight.requests.per.connection = 5 confluent.topic.producer.max.request.size = 1048576 confluent.topic.producer.metadata.max.age.ms = 300000 confluent.topic.producer.metadata.max.idle.ms = 300000 confluent.topic.producer.metric.reporters = [] confluent.topic.producer.metrics.num.samples = 2 confluent.topic.producer.metrics.recording.level = INFO confluent.topic.producer.metrics.sample.window.ms = 30000 confluent.topic.producer.partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner confluent.topic.producer.receive.buffer.bytes = 32768 confluent.topic.producer.reconnect.backoff.max.ms = 1000 confluent.topic.producer.reconnect.backoff.ms = 50 confluent.topic.producer.request.timeout.ms = 30000 confluent.topic.producer.retry.backoff.ms = 100 confluent.topic.producer.sasl.client.callback.handler.class = null confluent.topic.producer.sasl.jaas.config = null confluent.topic.producer.sasl.kerberos.kinit.cmd = /usr/bin/kinit confluent.topic.producer.sasl.kerberos.min.time.before.relogin = 60000 confluent.topic.producer.sasl.kerberos.service.name = null confluent.topic.producer.sasl.kerberos.ticket.renew.jitter = 0.05 confluent.topic.producer.sasl.kerberos.ticket.renew.window.factor = 0.8 confluent.topic.producer.sasl.login.callback.handler.class = null confluent.topic.producer.sasl.login.class = null confluent.topic.producer.sasl.login.refresh.buffer.seconds = 300 confluent.topic.producer.sasl.login.refresh.min.period.seconds = 60 confluent.topic.producer.sasl.login.refresh.window.factor = 0.8 confluent.topic.producer.sasl.login.refresh.window.jitter = 0.05 confluent.topic.producer.sasl.mechanism = GSSAPI confluent.topic.producer.security.protocol = PLAINTEXT confluent.topic.producer.security.providers = null confluent.topic.producer.send.buffer.bytes = 131072 confluent.topic.producer.socket.connection.setup.timeout.max.ms = 30000 confluent.topic.producer.socket.connection.setup.timeout.ms = 10000 confluent.topic.producer.ssl.cipher.suites = null confluent.topic.producer.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] confluent.topic.producer.ssl.endpoint.identification.algorithm = https confluent.topic.producer.ssl.engine.factory.class = null confluent.topic.producer.ssl.key.password = null confluent.topic.producer.ssl.keymanager.algorithm = SunX509 confluent.topic.producer.ssl.keystore.certificate.chain = null confluent.topic.producer.ssl.keystore.key = null confluent.topic.producer.ssl.keystore.location = null confluent.topic.producer.ssl.keystore.password = null confluent.topic.producer.ssl.keystore.type = JKS confluent.topic.producer.ssl.protocol = TLSv1.3 confluent.topic.producer.ssl.provider = null confluent.topic.producer.ssl.secure.random.implementation = null confluent.topic.producer.ssl.trustmanager.algorithm = PKIX confluent.topic.producer.ssl.truststore.certificates = null confluent.topic.producer.ssl.truststore.location = null confluent.topic.producer.ssl.truststore.password = null confluent.topic.producer.ssl.truststore.type = JKS confluent.topic.producer.transaction.timeout.ms = 60000 confluent.topic.producer.transactional.id = null confluent.topic.receive.buffer.bytes = 32768 confluent.topic.reconnect.backoff.max.ms = 1000 confluent.topic.reconnect.backoff.ms = 50 confluent.topic.replication.factor = 3 confluent.topic.request.timeout.ms = 30000 confluent.topic.retry.backoff.ms = 100 confluent.topic.sasl.client.callback.handler.class = null confluent.topic.sasl.jaas.config = null confluent.topic.sasl.kerberos.kinit.cmd = /usr/bin/kinit confluent.topic.sasl.kerberos.min.time.before.relogin = 60000 confluent.topic.sasl.kerberos.service.name = null confluent.topic.sasl.kerberos.ticket.renew.jitter = 0.05 confluent.topic.sasl.kerberos.ticket.renew.window.factor = 0.8 confluent.topic.sasl.login.callback.handler.class = null confluent.topic.sasl.login.class = null confluent.topic.sasl.login.refresh.buffer.seconds = 300 confluent.topic.sasl.login.refresh.min.period.seconds = 60 confluent.topic.sasl.login.refresh.window.factor = 0.8 confluent.topic.sasl.login.refresh.window.jitter = 0.05 confluent.topic.sasl.mechanism = GSSAPI confluent.topic.security.protocol = PLAINTEXT confluent.topic.security.providers = null confluent.topic.send.buffer.bytes = 131072 confluent.topic.socket.connection.setup.timeout.max.ms = 30000 confluent.topic.socket.connection.setup.timeout.ms = 10000 confluent.topic.ssl.cipher.suites = null confluent.topic.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] confluent.topic.ssl.endpoint.identification.algorithm = https confluent.topic.ssl.engine.factory.class = null confluent.topic.ssl.key.password = null confluent.topic.ssl.keymanager.algorithm = SunX509 confluent.topic.ssl.keystore.certificate.chain = null confluent.topic.ssl.keystore.key = null confluent.topic.ssl.keystore.location = null confluent.topic.ssl.keystore.password = null confluent.topic.ssl.keystore.type = JKS confluent.topic.ssl.protocol = TLSv1.3 confluent.topic.ssl.provider = null confluent.topic.ssl.secure.random.implementation = null confluent.topic.ssl.trustmanager.algorithm = PKIX confluent.topic.ssl.truststore.certificates = null confluent.topic.ssl.truststore.location = null confluent.topic.ssl.truststore.password = null confluent.topic.ssl.truststore.type = JKS connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = compose-connect-group 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 = 10000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 25 offset.storage.replication.factor = 1 offset.storage.topic = docker-connect-offsets plugin.path = [/usr/share/java, /usr/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 response.http.headers.config = rest.advertised.host.name = connect rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 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 = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 5 status.storage.replication.factor = 1 status.storage.topic = docker-connect-status task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true 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) [2022-05-11 10:22:59,350] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:22:59,355] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,510] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:22:59,511] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:22:59,511] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:22:59,511] INFO Kafka startTimeMs: 1652289779510 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,122] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,123] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,132] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,132] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,132] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,145] INFO Logging initialized @36311ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) [2022-05-11 10:23:00,207] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,207] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,215] INFO jetty-9.4.40.v20210413; built: 2021-04-13T20:42:42.668Z; git: b881a572662e1943a14ae12e7e1207989f218b74; jvm 11.0.11+9-LTS (org.eclipse.jetty.server.Server) [2022-05-11 10:23:00,249] INFO Started http_8083@4c8afab9{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector) [2022-05-11 10:23:00,249] INFO Started @36415ms (org.eclipse.jetty.server.Server) [2022-05-11 10:23:00,281] INFO Advertised URI: http://connect:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,281] INFO REST server listening at http://192.168.64.6:8083/, advertising URL http://connect:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,282] INFO Advertised URI: http://connect:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,282] INFO REST admin endpoints at http://connect:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,282] INFO Advertised URI: http://connect:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,287] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,288] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,293] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,294] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,294] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,294] INFO Kafka startTimeMs: 1652289780294 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,304] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,305] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,310] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,311] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,311] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,320] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy) [2022-05-11 10:23:00,332] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,333] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,337] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,338] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,338] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,338] INFO Kafka startTimeMs: 1652289780338 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,348] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,349] INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,352] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,352] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,352] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,358] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,358] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,358] INFO Kafka startTimeMs: 1652289780358 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,614] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [2022-05-11 10:23:00,616] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [2022-05-11 10:23:00,616] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,616] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,621] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,621] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,621] INFO Kafka startTimeMs: 1652289780621 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,638] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,638] INFO App info kafka.admin.client for adminclient-4 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,641] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,641] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,641] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,657] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,657] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,664] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,664] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,664] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,664] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,664] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,665] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,665] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,665] INFO Kafka startTimeMs: 1652289780665 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,679] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,680] INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,682] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,682] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,682] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,689] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,690] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,693] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,694] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,694] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,694] INFO Kafka startTimeMs: 1652289780694 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,704] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,704] INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,705] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,706] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,706] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,744] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,744] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,750] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,750] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,751] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,751] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,751] INFO Kafka startTimeMs: 1652289780751 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,759] INFO Kafka cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.connect.util.ConnectUtils) [2022-05-11 10:23:00,760] INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,761] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,761] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,761] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:00,807] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,807] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,807] INFO Kafka startTimeMs: 1652289780807 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,814] INFO Kafka Connect distributed worker initialization took 34131ms (org.apache.kafka.connect.cli.ConnectDistributed) [2022-05-11 10:23:00,814] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [2022-05-11 10:23:00,818] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,818] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:00,818] INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:00,818] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [2022-05-11 10:23:00,818] INFO Starting KafkaBasedLog with topic docker-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:00,819] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver 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 = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,822] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2022-05-11 10:23:00,823] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,823] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,823] INFO Kafka startTimeMs: 1652289780823 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,864] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [broker:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-1 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,889] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:00,890] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,890] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,890] INFO Kafka startTimeMs: 1652289780890 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,896] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [broker:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-compose-connect-group-1 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = compose-connect-group group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 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 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,896] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:00,905] INFO [Producer clientId=producer-1] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:00,942] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,942] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:00,943] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,943] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,943] INFO Kafka startTimeMs: 1652289780942 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:00,953] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:00,959] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Subscribed to partition(s): docker-connect-offsets-0, docker-connect-offsets-5, docker-connect-offsets-10, docker-connect-offsets-20, docker-connect-offsets-15, docker-connect-offsets-9, docker-connect-offsets-11, docker-connect-offsets-16, docker-connect-offsets-4, docker-connect-offsets-17, docker-connect-offsets-3, docker-connect-offsets-24, docker-connect-offsets-23, docker-connect-offsets-13, docker-connect-offsets-18, docker-connect-offsets-22, docker-connect-offsets-2, docker-connect-offsets-8, docker-connect-offsets-12, docker-connect-offsets-19, docker-connect-offsets-14, docker-connect-offsets-1, docker-connect-offsets-6, docker-connect-offsets-7, docker-connect-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer) [2022-05-11 10:23:00,965] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,966] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,967] INFO [Consumer clientId=consumer-compose-connect-group-1, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:00,992] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [2022-05-11 10:23:00,993] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [2022-05-11 10:23:00,995] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session) [2022-05-11 10:23:01,099] INFO Finished reading KafkaBasedLog for topic docker-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,100] INFO Started KafkaBasedLog for topic docker-connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,100] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [2022-05-11 10:23:01,103] INFO Worker started (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:01,103] INFO Starting KafkaBasedLog with topic docker-connect-status (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,118] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [broker:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-2 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,122] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,123] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,123] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,123] INFO Kafka startTimeMs: 1652289781123 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,127] INFO [Producer clientId=producer-2] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:01,127] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [broker:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-compose-connect-group-2 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = compose-connect-group group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 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 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,131] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,132] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,132] INFO Kafka startTimeMs: 1652289781131 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Subscribed to partition(s): docker-connect-status-0, docker-connect-status-1, docker-connect-status-4, docker-connect-status-2, docker-connect-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,136] INFO [Consumer clientId=consumer-compose-connect-group-2, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,442] INFO Finished reading KafkaBasedLog for topic docker-connect-status (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,442] INFO Started KafkaBasedLog for topic docker-connect-status (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,456] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [2022-05-11 10:23:01,456] INFO Starting KafkaBasedLog with topic docker-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,472] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [broker:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-3 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,492] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:01,495] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,495] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,495] INFO Kafka startTimeMs: 1652289781495 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,497] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [broker:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-compose-connect-group-3 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = compose-connect-group group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 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 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,499] INFO [Producer clientId=producer-3] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:01,504] WARN The configuration 'log4j.loggers' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'producer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'expose.internal.connect.endpoints' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'rest.advertised.host.name' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'consumer.interceptor.classes' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2022-05-11 10:23:01,505] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,505] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,505] INFO Kafka startTimeMs: 1652289781505 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:01,513] INFO [Consumer clientId=consumer-compose-connect-group-3, groupId=compose-connect-group] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:01,513] INFO [Consumer clientId=consumer-compose-connect-group-3, groupId=compose-connect-group] Subscribed to partition(s): docker-connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [2022-05-11 10:23:01,513] INFO [Consumer clientId=consumer-compose-connect-group-3, groupId=compose-connect-group] Seeking to EARLIEST offset of partition docker-connect-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2022-05-11 10:23:01,529] INFO Successfully processed removal of connector 'star-custom-connector-v3' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [2022-05-11 10:23:01,534] INFO Finished reading KafkaBasedLog for topic docker-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,534] INFO Started KafkaBasedLog for topic docker-connect-configs (org.apache.kafka.connect.util.KafkaBasedLog) [2022-05-11 10:23:01,534] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [2022-05-11 10:23:01,534] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,593] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:01,594] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Discovered group coordinator broker:29092 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2022-05-11 10:23:01,599] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [2022-05-11 10:23:01,600] INFO [Worker clientId=connect-1, groupId=compose-connect-group] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2022-05-11 10:23:01,635] INFO [Worker clientId=connect-1, groupId=compose-connect-group] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2022-05-11 10:23:01,651] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Successfully joined group with generation Generation{generationId=36, memberId='connect-1-58489958-a040-4d29-8610-d83d573ece46', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2022-05-11 10:23:01,753] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Successfully synced group in generation Generation{generationId=36, memberId='connect-1-58489958-a040-4d29-8610-d83d573ece46', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2022-05-11 10:23:01,761] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Joined group at generation 36 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-58489958-a040-4d29-8610-d83d573ece46', leaderUrl='http://connect:8083/', offset=239, connectorIds=[star-custom-connector-v4], taskIds=[star-custom-connector-v4-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,763] WARN [Worker clientId=connect-1, groupId=compose-connect-group] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,763] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Current config state offset -1 is behind group assignment 239, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,779] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Finished reading to end of log and updated config snapshot, new config log offset: 239 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,779] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Starting connectors and tasks using config offset 239 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,782] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Starting connector star-custom-connector-v4 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,787] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Starting task star-custom-connector-v4-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:01,808] INFO Creating task star-custom-connector-v4-0 (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:01,809] INFO Creating connector star-custom-connector-v4 of type io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:01,921] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 transforms = [changeTopicCase] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig) [2022-05-11 10:23:01,984] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 transforms = [changeTopicCase] transforms.changeTopicCase.from = UPPER_UNDERSCORE transforms.changeTopicCase.negate = false transforms.changeTopicCase.predicate = transforms.changeTopicCase.to = LOWER_UNDERSCORE transforms.changeTopicCase.type = class com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [2022-05-11 10:23:02,048] INFO TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.TaskConfig) [2022-05-11 10:23:02,055] INFO Instantiated task star-custom-connector-v4-0 with version 1.3.0.CR1 of type io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,066] INFO AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig) schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig) [2022-05-11 10:23:02,132] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [2022-05-11 10:23:02,134] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] transforms.changeTopicCase.from = UPPER_UNDERSCORE transforms.changeTopicCase.negate = false transforms.changeTopicCase.predicate = transforms.changeTopicCase.to = LOWER_UNDERSCORE transforms.changeTopicCase.type = class com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [2022-05-11 10:23:02,142] INFO Instantiated connector star-custom-connector-v4 with version 1.3.0.CR1 of type class io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,149] INFO Finished creating connector star-custom-connector-v4 (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,178] INFO KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig) [2022-05-11 10:23:02,186] INFO KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] specific.avro.reader = false use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig) [2022-05-11 10:23:02,286] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 scrub.invalid.names = false (io.confluent.connect.avro.AvroDataConfig) [2022-05-11 10:23:02,287] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task star-custom-connector-v4-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,287] INFO AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.connect.avro.AvroConverterConfig) [2022-05-11 10:23:02,287] INFO KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroSerializerConfig) [2022-05-11 10:23:02,287] INFO KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.token = [hidden] key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 proxy.host = proxy.port = -1 schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://schema-registry:8081] specific.avro.reader = false use.latest.version = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig) [2022-05-11 10:23:02,288] INFO AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 scrub.invalid.names = false (io.confluent.connect.avro.AvroDataConfig) [2022-05-11 10:23:02,288] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task star-custom-connector-v4-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,288] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task star-custom-connector-v4-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,295] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [2022-05-11 10:23:02,298] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] transforms.changeTopicCase.from = UPPER_UNDERSCORE transforms.changeTopicCase.negate = false transforms.changeTopicCase.predicate = transforms.changeTopicCase.to = LOWER_UNDERSCORE transforms.changeTopicCase.type = class com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [2022-05-11 10:23:02,303] INFO ChangeTopicCaseConfig values: from = UPPER_UNDERSCORE to = LOWER_UNDERSCORE (com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCaseConfig) [2022-05-11 10:23:02,322] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase} (org.apache.kafka.connect.runtime.Worker) [2022-05-11 10:23:02,327] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [broker:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-star-custom-connector-v4-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 2147483647 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,333] INFO HV000001: Hibernate Validator 6.1.7.Final (org.hibernate.validator.internal.util.Version) [2022-05-11 10:23:02,346] WARN The configuration 'metrics.context.resource.connector' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.resource.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.resource.task' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig) [2022-05-11 10:23:02,353] INFO Kafka version: 6.2.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:02,353] INFO Kafka commitId: 5c753752ae1445a1 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:02,353] INFO Kafka startTimeMs: 1652289782353 (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:02,381] INFO [Producer clientId=connector-producer-star-custom-connector-v4-0] Cluster ID: jQsInRaQQcqTO3RG-iB6Fw (org.apache.kafka.clients.Metadata) [2022-05-11 10:23:02,390] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:02,414] ERROR The 'database.out.server.name' value is invalid: A value is required (io.debezium.connector.common.BaseSourceTask) [2022-05-11 10:23:02,430] WARN Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. (io.debezium.config.Configuration) [2022-05-11 10:23:02,430] WARN Using configuration property "table.blacklist" is deprecated and will be removed in future versions. Please use "table.exclude.list" instead. (io.debezium.config.Configuration) [2022-05-11 10:23:02,436] INFO WorkerSourceTask{id=star-custom-connector-v4-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [2022-05-11 10:23:02,437] ERROR WorkerSourceTask{id=star-custom-connector-v4-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask) org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of OracleConnectorTask; check the logs for details at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:96) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:225) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:182) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:231) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) [2022-05-11 10:23:02,439] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask) [2022-05-11 10:23:02,443] WARN Could not stop task (org.apache.kafka.connect.runtime.WorkerSourceTask) java.lang.NullPointerException at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:129) at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:206) at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:176) at org.apache.kafka.connect.runtime.WorkerSourceTask.close(WorkerSourceTask.java:170) at org.apache.kafka.connect.runtime.WorkerTask.doClose(WorkerTask.java:161) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:187) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:231) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) [2022-05-11 10:23:02,444] INFO [Producer clientId=connector-producer-star-custom-connector-v4-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2022-05-11 10:23:02,454] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:02,454] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:02,454] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-05-11 10:23:02,454] INFO App info kafka.producer for connector-producer-star-custom-connector-v4-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-05-11 10:23:02,467] INFO [Worker clientId=connect-1, groupId=compose-connect-group] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2022-05-11 10:23:02,470] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [2022-05-11 10:23:02,470] 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 = star-custom-connector-v4 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [changeTopicCase] transforms.changeTopicCase.from = UPPER_UNDERSCORE transforms.changeTopicCase.negate = false transforms.changeTopicCase.predicate = transforms.changeTopicCase.to = LOWER_UNDERSCORE transforms.changeTopicCase.type = class com.github.jcustenborder.kafka.connect.transform.common.ChangeTopicCase value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [2022-05-11 10:23:02,808] INFO Started o.e.j.s.ServletContextHandler@b8d2866{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [2022-05-11 10:23:02,809] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [2022-05-11 10:23:02,809] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [2022-05-11 10:23:12,385] INFO WorkerSourceTask{id=star-custom-connector-v4-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask)