[2022-01-28 10:52:13,225] 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, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../logs, -Dlog4j.configuration=file:bin/../config/connect-log4j.properties jvm.spec = Ubuntu, OpenJDK 64-Bit Server VM, 11.0.13, 11.0.13+8-Ubuntu-0ubuntu1.20.04 jvm.classpath = /home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/activation-1.1.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/aopalliance-repackaged-2.6.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/argparse4j-0.7.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/audience-annotations-0.5.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/commons-cli-1.4.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/commons-lang3-3.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-api-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-basic-auth-extension-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-file-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-json-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-mirror-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-mirror-client-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-runtime-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/connect-transforms-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/hk2-api-2.6.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/hk2-locator-2.6.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/hk2-utils-2.6.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-annotations-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-core-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-databind-2.10.5.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-dataformat-csv-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-datatype-jdk8-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-jaxrs-base-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-jaxrs-json-provider-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-module-jaxb-annotations-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-module-paranamer-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jackson-module-scala_2.13-2.10.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.activation-api-1.2.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.annotation-api-1.3.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.inject-2.6.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.validation-api-2.0.2.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/javassist-3.27.0-GA.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/javax.servlet-api-3.1.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/javax.ws.rs-api-2.1.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jaxb-api-2.3.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-client-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-common-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-container-servlet-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-container-servlet-core-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-hk2-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jersey-server-2.34.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-client-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-continuation-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-http-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-io-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-security-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-server-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-servlet-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-servlets-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-util-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jetty-util-ajax-9.4.43.v20210629.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jline-3.12.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/jopt-simple-5.0.4.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka_2.13-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka_2.13-2.8.1-sources.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-clients-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-log4j-appender-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-metadata-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-raft-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-shell-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-streams-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-streams-examples-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-streams-scala_2.13-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-streams-test-utils-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/kafka-tools-2.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/log4j-1.2.17.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/lz4-java-1.7.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/maven-artifact-3.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/metrics-core-2.2.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-buffer-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-codec-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-common-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-handler-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-resolver-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-transport-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/osgi-resource-locator-1.0.3.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/paranamer-2.8.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/plexus-utils-3.2.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/reflections-0.9.12.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/rocksdbjni-5.18.4.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/scala-collection-compat_2.13-2.3.0.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/scala-java8-compat_2.13-0.9.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/scala-library-2.13.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/scala-logging_2.13-3.9.2.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/scala-reflect-2.13.5.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/slf4j-api-1.7.30.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/slf4j-log4j12-1.7.30.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/snappy-java-1.1.8.1.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/zookeeper-3.5.9.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/zookeeper-jute-3.5.9.jar:/home/sschall/Downloads/kafka_2.13-2.8.1/bin/../libs/zstd-jni-1.4.9-1.jar os.spec = Linux, amd64, 5.13.0-27-generic os.vcpus = 4 (org.apache.kafka.connect.runtime.WorkerInfo:71) [2022-01-28 10:52:13,231] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:92) [2022-01-28 10:52:15,167] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:269) [2022-01-28 10:52:15,168] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,169] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,169] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,169] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,169] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,169] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,170] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,170] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,170] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,170] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,170] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,171] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,171] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,174] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,174] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,174] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,175] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,175] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,175] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,176] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,176] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,176] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,176] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,176] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,177] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,178] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,179] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,180] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,181] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,181] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,181] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:198) [2022-01-28 10:52:15,183] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,183] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,184] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,185] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,185] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,185] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,185] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,185] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,186] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,187] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,187] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,187] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,187] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,187] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,188] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,188] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,188] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,188] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,188] INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,189] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,189] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,189] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,189] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,189] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,189] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,190] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,190] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:424) [2022-01-28 10:52:15,190] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,190] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,190] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:427) [2022-01-28 10:52:15,270] INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = connect-configs connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = None group.id = connect-cluster header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.json.JsonConverter 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 = connect-offsets plugin.path = null 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 = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI 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 = connect-status task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig:372) [2022-01-28 10:52:15,271] WARN Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. (org.apache.kafka.connect.runtime.WorkerConfig:420) [2022-01-28 10:52:15,272] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:15,275] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:15,358] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,358] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,358] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,358] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,359] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,360] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:15,360] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:15,361] INFO Kafka startTimeMs: 1643363535360 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:15,704] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:15,705] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:15,714] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:15,715] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:15,715] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:15,739] INFO Logging initialized @3040ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:170) [2022-01-28 10:52:15,791] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:132) [2022-01-28 10:52:15,793] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:204) [2022-01-28 10:52:15,805] INFO jetty-9.4.43.v20210629; built: 2021-06-30T11:07:22.254Z; git: 526006ecfa3af7f1a27ef3a288e2bef7ea9dd7e8; jvm 11.0.13+8-Ubuntu-0ubuntu1.20.04 (org.eclipse.jetty.server.Server:375) [2022-01-28 10:52:15,836] INFO Started http_8083@1edb61b1{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:331) [2022-01-28 10:52:15,836] INFO Started @3137ms (org.eclipse.jetty.server.Server:415) [2022-01-28 10:52:15,868] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:371) [2022-01-28 10:52:15,868] INFO REST server listening at http://127.0.1.1:8083/, advertising URL http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:219) [2022-01-28 10:52:15,869] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:371) [2022-01-28 10:52:15,869] INFO REST admin endpoints at http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:220) [2022-01-28 10:52:15,869] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:371) [2022-01-28 10:52:15,874] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:15,875] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:15,879] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,879] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,879] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,879] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,880] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:15,880] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:15,880] INFO Kafka startTimeMs: 1643363535880 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:15,907] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:15,908] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:15,914] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:15,914] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:15,914] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:15,921] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45) [2022-01-28 10:52:15,929] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:15,930] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:15,937] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,938] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,939] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,939] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:15,939] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:15,939] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:15,939] INFO Kafka startTimeMs: 1643363535939 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:15,971] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:15,972] INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:15,977] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:15,977] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:15,978] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:15,980] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:15,980] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:15,980] INFO Kafka startTimeMs: 1643363535980 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,135] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:16,139] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:16,139] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:16,140] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:16,144] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,144] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,144] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,144] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,145] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,146] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,146] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,146] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,146] INFO Kafka startTimeMs: 1643363536146 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,161] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:16,162] INFO App info kafka.admin.client for adminclient-4 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:16,166] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:16,166] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:16,166] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:16,175] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:16,175] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:16,178] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,178] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,179] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,179] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,179] INFO Kafka startTimeMs: 1643363536179 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,192] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:16,193] INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:16,195] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:16,195] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:16,196] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:16,200] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:16,201] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:16,205] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,205] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,205] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,205] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,205] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,205] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,206] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,206] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,206] INFO Kafka startTimeMs: 1643363536206 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,229] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:16,229] INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:16,231] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:16,232] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:16,232] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:16,245] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:49) [2022-01-28 10:52:16,246] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:16,248] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,248] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,248] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,248] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,248] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,248] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,249] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,249] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,249] INFO Kafka startTimeMs: 1643363536249 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,261] INFO Kafka cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.connect.util.ConnectUtils:65) [2022-01-28 10:52:16,262] INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:16,263] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:16,264] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:16,264] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:16,284] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,284] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,285] INFO Kafka startTimeMs: 1643363536284 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,288] INFO Kafka Connect distributed worker initialization took 3057ms (org.apache.kafka.connect.cli.ConnectDistributed:138) [2022-01-28 10:52:16,289] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51) [2022-01-28 10:52:16,290] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:224) [2022-01-28 10:52:16,290] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:308) [2022-01-28 10:52:16,291] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:191) [2022-01-28 10:52:16,291] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:144) [2022-01-28 10:52:16,291] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:162) [2022-01-28 10:52:16,291] INFO AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 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:372) [2022-01-28 10:52:16,294] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,294] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,295] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,296] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,296] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:380) [2022-01-28 10:52:16,296] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,296] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,296] INFO Kafka startTimeMs: 1643363536296 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,356] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:241) [2022-01-28 10:52:16,440] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] 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:372) [2022-01-28 10:52:16,475] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,476] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,477] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,478] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,478] INFO Kafka startTimeMs: 1643363536477 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,506] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-connect-cluster-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 = connect-cluster 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:372) [2022-01-28 10:52:16,515] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:334) [2022-01-28 10:52:16,529] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:339) [2022-01-28 10:52:16,531] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:132) [2022-01-28 10:52:16,533] INFO [Producer clientId=producer-1] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:16,546] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,546] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,547] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,547] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,547] INFO Kafka startTimeMs: 1643363536547 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,567] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:16,572] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Subscribed to partition(s): connect-offsets-0, connect-offsets-5, connect-offsets-10, connect-offsets-20, connect-offsets-15, connect-offsets-9, connect-offsets-11, connect-offsets-4, connect-offsets-16, connect-offsets-17, connect-offsets-3, connect-offsets-24, connect-offsets-23, connect-offsets-13, connect-offsets-18, connect-offsets-22, connect-offsets-8, connect-offsets-2, connect-offsets-12, connect-offsets-19, connect-offsets-14, connect-offsets-1, connect-offsets-6, connect-offsets-7, connect-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1120) [2022-01-28 10:52:16,575] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,576] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,576] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,577] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,578] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,635] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,637] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,637] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,637] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,638] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,638] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,638] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,638] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,638] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,639] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,639] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,639] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,639] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,639] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,640] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,640] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,640] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,640] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,640] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,641] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,641] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,641] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,641] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,641] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,642] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting offset for partition connect-offsets-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,792] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:202) [2022-01-28 10:52:16,792] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:204) [2022-01-28 10:52:16,793] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:146) [2022-01-28 10:52:16,796] INFO Worker started (org.apache.kafka.connect.runtime.Worker:198) [2022-01-28 10:52:16,796] INFO Starting KafkaBasedLog with topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:162) [2022-01-28 10:52:16,833] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] 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:372) [2022-01-28 10:52:16,848] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,848] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,848] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:16,849] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,849] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,849] INFO Kafka startTimeMs: 1643363536849 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,851] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-connect-cluster-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 = connect-cluster 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:372) [2022-01-28 10:52:16,856] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,856] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,856] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,856] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,856] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:16,857] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:16,857] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:16,857] INFO Kafka startTimeMs: 1643363536857 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:16,865] INFO [Producer clientId=producer-2] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:16,872] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Subscribed to partition(s): connect-status-0, connect-status-4, connect-status-1, connect-status-2, connect-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer:1120) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,874] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:16,890] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,890] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,890] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,891] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,891] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting offset for partition connect-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:16,971] INFO Finished reading KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:202) [2022-01-28 10:52:16,972] INFO Started KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:204) [2022-01-28 10:52:16,973] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:275) [2022-01-28 10:52:16,973] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:162) [2022-01-28 10:52:16,985] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] 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:372) [2022-01-28 10:52:17,000] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,001] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,002] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:17,002] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:17,002] INFO Kafka startTimeMs: 1643363537001 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:17,003] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-connect-cluster-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 = connect-cluster 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:372) [2022-01-28 10:52:17,007] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:17,008] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:17,008] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:17,009] INFO Kafka startTimeMs: 1643363537008 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:17,017] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:17,022] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1120) [2022-01-28 10:52:17,022] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Seeking to EARLIEST offset of partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:619) [2022-01-28 10:52:17,026] INFO [Producer clientId=producer-3] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:17,039] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting offset for partition connect-configs-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:17,051] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,052] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,053] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,053] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,054] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,055] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,057] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,057] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,058] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,058] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,059] INFO Successfully processed removal of connector 'local-file-sink3' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,060] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,060] INFO Successfully processed removal of connector 'local-file-source' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,061] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:17,065] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:202) [2022-01-28 10:52:17,066] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:204) [2022-01-28 10:52:17,066] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:290) [2022-01-28 10:52:17,066] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:312) [2022-01-28 10:52:17,083] INFO [Worker clientId=connect-1, groupId=connect-cluster] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:17,087] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator sschall-ThinkPad-T470s:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:850) [2022-01-28 10:52:17,089] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221) [2022-01-28 10:52:17,090] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:17,112] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:17,130] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=9, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:17,263] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=9, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:17,263] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 9 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', leaderUrl='http://127.0.1.1:8083/', offset=98, connectorIds=[local-file-source3], taskIds=[local-file-source3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1699) [2022-01-28 10:52:17,268] WARN [Worker clientId=connect-1, groupId=connect-cluster] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1119) [2022-01-28 10:52:17,268] INFO [Worker clientId=connect-1, groupId=connect-cluster] Current config state offset -1 is behind group assignment 98, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1183) [2022-01-28 10:52:17,280] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished reading to end of log and updated config snapshot, new config log offset: 98 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1190) [2022-01-28 10:52:17,280] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 98 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244) Jan. 28, 2022 10:52:17 VORM. org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNUNG: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. Jan. 28, 2022 10:52:17 VORM. org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNUNG: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. Jan. 28, 2022 10:52:17 VORM. org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNUNG: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. Jan. 28, 2022 10:52:17 VORM. org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNUNG: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. [2022-01-28 10:52:17,310] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connector local-file-source3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1321) [2022-01-28 10:52:17,333] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting task local-file-source3-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1286) [2022-01-28 10:52:17,345] INFO Creating task local-file-source3-0 (org.apache.kafka.connect.runtime.Worker:505) [2022-01-28 10:52:17,343] INFO Creating connector local-file-source3 of type FileStreamSource (org.apache.kafka.connect.runtime.Worker:271) [2022-01-28 10:52:17,367] INFO ConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:372) [2022-01-28 10:52:17,369] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:372) [2022-01-28 10:52:17,369] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:17,369] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:17,375] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.TaskConfig:372) [2022-01-28 10:52:17,380] INFO Instantiated task local-file-source3-0 with version 2.8.1 of type org.apache.kafka.connect.file.FileStreamSourceTask (org.apache.kafka.connect.runtime.Worker:520) [2022-01-28 10:52:17,381] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:17,404] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task local-file-source3-0 using the worker config (org.apache.kafka.connect.runtime.Worker:533) [2022-01-28 10:52:17,404] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:17,405] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task local-file-source3-0 using the worker config (org.apache.kafka.connect.runtime.Worker:539) [2022-01-28 10:52:17,405] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task local-file-source3-0 using the worker config (org.apache.kafka.connect.runtime.Worker:546) [2022-01-28 10:52:17,407] INFO Instantiated connector local-file-source3 with version 2.8.1 of type class org.apache.kafka.connect.file.FileStreamSourceConnector (org.apache.kafka.connect.runtime.Worker:281) [2022-01-28 10:52:17,421] INFO Finished creating connector local-file-source3 (org.apache.kafka.connect.runtime.Worker:306) [2022-01-28 10:52:17,415] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:372) [2022-01-28 10:52:17,434] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:17,434] INFO AbstractConfig values: batch.size = 2000 file = tes3.txt topic = [connect-test3] (org.apache.kafka.common.config.AbstractConfig:372) [2022-01-28 10:52:17,438] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:600) [2022-01-28 10:52:17,447] INFO ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-local-file-source3-0 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 = 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:372) [2022-01-28 10:52:17,457] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,458] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:380) [2022-01-28 10:52:17,458] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:17,458] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:17,458] INFO Kafka startTimeMs: 1643363537458 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:17,485] INFO [Producer clientId=connector-producer-local-file-source3-0] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:17,495] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272) [2022-01-28 10:52:17,513] INFO WorkerSourceTask{id=local-file-source3-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:232) [2022-01-28 10:52:17,542] INFO WorkerSourceTask{id=local-file-source3-0} Executing source task (org.apache.kafka.connect.runtime.WorkerSourceTask:238) [2022-01-28 10:52:17,570] INFO [Worker clientId=connect-1, groupId=connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1587) [2022-01-28 10:52:17,628] INFO SourceConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:372) [2022-01-28 10:52:17,629] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSource 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 = local-file-source3 predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) Jan. 28, 2022 10:52:17 VORM. org.glassfish.jersey.internal.Errors logErrors WARNUNG: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. [2022-01-28 10:52:17,711] INFO Started o.e.j.s.ServletContextHandler@32b9bd12{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:915) [2022-01-28 10:52:17,712] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:319) [2022-01-28 10:52:17,712] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57) [2022-01-28 10:52:27,490] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:52:30,296] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:372) [2022-01-28 10:52:30,309] INFO [Worker clientId=connect-1, groupId=connect-cluster] Connector local-file-sink config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1543) [2022-01-28 10:52:30,311] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221) [2022-01-28 10:52:30,311] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:30,316] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=10, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:30,320] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=10, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:30,321] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 10 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', leaderUrl='http://127.0.1.1:8083/', offset=100, connectorIds=[local-file-sink, local-file-source3], taskIds=[local-file-source3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1699) [2022-01-28 10:52:30,322] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 100 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244) [2022-01-28 10:52:30,322] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connector local-file-sink (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1321) [2022-01-28 10:52:30,323] INFO Creating connector local-file-sink of type FileStreamSink (org.apache.kafka.connect.runtime.Worker:271) [2022-01-28 10:52:30,323] INFO SinkConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SinkConnectorConfig:372) [2022-01-28 10:52:30,323] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:30,324] INFO Instantiated connector local-file-sink with version 2.8.1 of type class org.apache.kafka.connect.file.FileStreamSinkConnector (org.apache.kafka.connect.runtime.Worker:281) [2022-01-28 10:52:30,325] INFO Finished creating connector local-file-sink (org.apache.kafka.connect.runtime.Worker:306) [2022-01-28 10:52:30,325] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272) [2022-01-28 10:52:30,326] INFO AbstractConfig values: file = test.sink.txt (org.apache.kafka.common.config.AbstractConfig:372) [2022-01-28 10:52:30,328] INFO SinkConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SinkConnectorConfig:372) [2022-01-28 10:52:30,330] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:30,354] INFO [Worker clientId=connect-1, groupId=connect-cluster] Tasks [local-file-sink-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1558) [2022-01-28 10:52:30,356] INFO [Worker clientId=connect-1, groupId=connect-cluster] Handling task config update by restarting tasks [] (org.apache.kafka.connect.runtime.distributed.DistributedHerder:674) [2022-01-28 10:52:30,356] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221) [2022-01-28 10:52:30,356] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:30,360] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=11, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:30,365] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=11, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:30,365] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 11 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', leaderUrl='http://127.0.1.1:8083/', offset=102, connectorIds=[local-file-sink, local-file-source3], taskIds=[local-file-sink-0, local-file-source3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1699) [2022-01-28 10:52:30,366] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 102 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244) [2022-01-28 10:52:30,366] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting task local-file-sink-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1286) [2022-01-28 10:52:30,366] INFO Creating task local-file-sink-0 (org.apache.kafka.connect.runtime.Worker:505) [2022-01-28 10:52:30,367] INFO ConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink 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 = local-file-sink predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig:372) [2022-01-28 10:52:30,368] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink 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 = local-file-sink predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:30,368] INFO TaskConfig values: task.class = class org.apache.kafka.connect.file.FileStreamSinkTask (org.apache.kafka.connect.runtime.TaskConfig:372) [2022-01-28 10:52:30,368] INFO Instantiated task local-file-sink-0 with version 2.8.1 of type org.apache.kafka.connect.file.FileStreamSinkTask (org.apache.kafka.connect.runtime.Worker:520) [2022-01-28 10:52:30,369] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:30,369] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task local-file-sink-0 using the worker config (org.apache.kafka.connect.runtime.Worker:533) [2022-01-28 10:52:30,369] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig:372) [2022-01-28 10:52:30,370] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task local-file-sink-0 using the worker config (org.apache.kafka.connect.runtime.Worker:539) [2022-01-28 10:52:30,370] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task local-file-sink-0 using the worker config (org.apache.kafka.connect.runtime.Worker:546) [2022-01-28 10:52:30,370] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:626) [2022-01-28 10:52:30,371] INFO SinkConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SinkConnectorConfig:372) [2022-01-28 10:52:30,371] INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = FileStreamSink errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 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 = local-file-sink predicates = [] tasks.max = 1 topics = [connect-test] topics.regex = transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372) [2022-01-28 10:52:30,372] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connector-consumer-local-file-sink-0 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-local-file-sink 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:372) [2022-01-28 10:52:30,380] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:30,380] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:380) [2022-01-28 10:52:30,380] INFO Kafka version: 2.8.1 (org.apache.kafka.common.utils.AppInfoParser:119) [2022-01-28 10:52:30,380] INFO Kafka commitId: 839b886f9b732b15 (org.apache.kafka.common.utils.AppInfoParser:120) [2022-01-28 10:52:30,380] INFO Kafka startTimeMs: 1643363550380 (org.apache.kafka.common.utils.AppInfoParser:121) [2022-01-28 10:52:30,386] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272) [2022-01-28 10:52:30,390] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Subscribed to topic(s): connect-test (org.apache.kafka.clients.consumer.KafkaConsumer:965) [2022-01-28 10:52:30,391] INFO WorkerSinkTask{id=local-file-sink-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:310) [2022-01-28 10:52:30,391] INFO WorkerSinkTask{id=local-file-sink-0} Executing sink task (org.apache.kafka.connect.runtime.WorkerSinkTask:196) [2022-01-28 10:52:30,431] WARN [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Error while fetching metadata with correlation id 2 : {connect-test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:1100) [2022-01-28 10:52:30,432] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Cluster ID: icvKdWGJS5eC9PfrI45bfw (org.apache.kafka.clients.Metadata:279) [2022-01-28 10:52:30,432] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Discovered group coordinator sschall-ThinkPad-T470s:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:850) [2022-01-28 10:52:30,440] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:30,452] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:30,457] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Successfully joined group with generation Generation{generationId=3, memberId='connector-consumer-local-file-sink-0-d7933eed-ccde-4408-92d0-f3b3c23c8f63', protocol='range'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:30,536] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Finished assignment for group at generation 3: {connector-consumer-local-file-sink-0-d7933eed-ccde-4408-92d0-f3b3c23c8f63=Assignment(partitions=[connect-test-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:626) [2022-01-28 10:52:30,542] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Successfully synced group in generation Generation{generationId=3, memberId='connector-consumer-local-file-sink-0-d7933eed-ccde-4408-92d0-f3b3c23c8f63', protocol='range'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:30,542] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Notifying assignor about the new Assignment(partitions=[connect-test-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:276) [2022-01-28 10:52:30,542] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Adding newly assigned partitions: connect-test-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:288) [2022-01-28 10:52:30,549] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Found no committed offset for partition connect-test-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1362) [2022-01-28 10:52:30,551] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Resetting offset for partition connect-test-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[sschall-ThinkPad-T470s:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:398) [2022-01-28 10:52:37,495] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:52:42,214] INFO Successfully processed removal of connector 'local-file-sink' (org.apache.kafka.connect.storage.KafkaConfigBackingStore:597) [2022-01-28 10:52:42,218] INFO [Worker clientId=connect-1, groupId=connect-cluster] Connector local-file-sink config removed (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1530) [2022-01-28 10:52:42,222] INFO [Worker clientId=connect-1, groupId=connect-cluster] Handling connector-only config update by stopping connector local-file-sink (org.apache.kafka.connect.runtime.distributed.DistributedHerder:620) [2022-01-28 10:52:42,222] INFO Stopping connector local-file-sink (org.apache.kafka.connect.runtime.Worker:382) [2022-01-28 10:52:42,222] INFO Scheduled shutdown for WorkerConnector{id=local-file-sink} (org.apache.kafka.connect.runtime.WorkerConnector:248) [2022-01-28 10:52:42,223] INFO Completed shutdown for WorkerConnector{id=local-file-sink} (org.apache.kafka.connect.runtime.WorkerConnector:268) [2022-01-28 10:52:42,226] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221) [2022-01-28 10:52:42,226] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:42,235] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=12, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:42,243] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=12, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:42,246] INFO Stopping connector local-file-sink (org.apache.kafka.connect.runtime.Worker:382) [2022-01-28 10:52:42,247] WARN Ignoring stop request for unowned connector local-file-sink (org.apache.kafka.connect.runtime.Worker:385) [2022-01-28 10:52:42,247] WARN Ignoring await stop request for non-present connector local-file-sink (org.apache.kafka.connect.runtime.Worker:410) [2022-01-28 10:52:42,247] INFO Stopping task local-file-sink-0 (org.apache.kafka.connect.runtime.Worker:830) [2022-01-28 10:52:42,250] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Revoke previously assigned partitions connect-test-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:307) [2022-01-28 10:52:42,250] INFO [Consumer clientId=connector-consumer-local-file-sink-0, groupId=connect-local-file-sink] Member connector-consumer-local-file-sink-0-d7933eed-ccde-4408-92d0-f3b3c23c8f63 sending LeaveGroup request to coordinator sschall-ThinkPad-T470s:9092 (id: 2147483647 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1045) [2022-01-28 10:52:42,264] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:52:42,264] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:52:42,264] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:52:42,269] INFO App info kafka.consumer for connector-consumer-local-file-sink-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:52:42,283] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1777) [2022-01-28 10:52:42,286] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished flushing status backing store in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1796) [2022-01-28 10:52:42,286] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 12 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', leaderUrl='http://127.0.1.1:8083/', offset=104, connectorIds=[local-file-source3], taskIds=[local-file-source3-0], revokedConnectorIds=[local-file-sink], revokedTaskIds=[local-file-sink-0], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1699) [2022-01-28 10:52:42,289] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 104 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244) [2022-01-28 10:52:42,294] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272) [2022-01-28 10:52:42,294] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:221) [2022-01-28 10:52:42,294] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:540) [2022-01-28 10:52:42,303] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=13, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:596) [2022-01-28 10:52:42,313] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=13, memberId='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', protocol='sessioned'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:760) [2022-01-28 10:52:42,314] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 13 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8', leaderUrl='http://127.0.1.1:8083/', offset=104, connectorIds=[local-file-source3], taskIds=[local-file-source3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1699) [2022-01-28 10:52:42,315] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 104 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1244) [2022-01-28 10:52:42,316] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1272) [2022-01-28 10:52:47,497] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:52:57,498] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:53:07,500] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:53:15,050] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67) [2022-01-28 10:53:15,051] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:327) [2022-01-28 10:53:15,073] INFO Stopped http_8083@1edb61b1{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:381) [2022-01-28 10:53:15,074] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:149) [2022-01-28 10:53:15,084] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:344) [2022-01-28 10:53:15,084] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:718) [2022-01-28 10:53:15,085] INFO [Worker clientId=connect-1, groupId=connect-cluster] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:683) [2022-01-28 10:53:15,094] INFO Stopping connector local-file-source3 (org.apache.kafka.connect.runtime.Worker:382) [2022-01-28 10:53:15,095] INFO Scheduled shutdown for WorkerConnector{id=local-file-source3} (org.apache.kafka.connect.runtime.WorkerConnector:248) [2022-01-28 10:53:15,097] INFO Completed shutdown for WorkerConnector{id=local-file-source3} (org.apache.kafka.connect.runtime.WorkerConnector:268) [2022-01-28 10:53:15,099] INFO Stopping task local-file-source3-0 (org.apache.kafka.connect.runtime.Worker:830) [2022-01-28 10:53:15,585] INFO WorkerSourceTask{id=local-file-source3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510) [2022-01-28 10:53:15,587] INFO [Producer clientId=connector-producer-local-file-source3-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204) [2022-01-28 10:53:15,598] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,598] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,599] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,600] INFO App info kafka.producer for connector-producer-local-file-source3-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,614] INFO [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-cb528b45-0a0d-48b6-9ce5-66502d20f2f8 sending LeaveGroup request to coordinator sschall-ThinkPad-T470s:9092 (id: 2147483647 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1045) [2022-01-28 10:53:15,616] WARN [Worker clientId=connect-1, groupId=connect-cluster] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1026) [2022-01-28 10:53:15,616] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,617] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,617] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,640] INFO App info kafka.connect for connect-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,641] INFO Stopping KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:208) [2022-01-28 10:53:15,646] INFO [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204) [2022-01-28 10:53:15,657] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,666] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,666] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,667] INFO App info kafka.producer for producer-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,670] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,671] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,672] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,677] INFO App info kafka.consumer for consumer-connect-cluster-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,677] INFO Stopped KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:237) [2022-01-28 10:53:15,677] INFO Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:295) [2022-01-28 10:53:15,678] INFO Stopping KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:208) [2022-01-28 10:53:15,678] INFO [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204) [2022-01-28 10:53:15,681] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,681] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,682] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,682] INFO App info kafka.producer for producer-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,682] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,682] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,683] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,686] INFO App info kafka.consumer for consumer-connect-cluster-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,686] INFO Stopped KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:237) [2022-01-28 10:53:15,686] INFO Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:303) [2022-01-28 10:53:15,686] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:205) [2022-01-28 10:53:15,687] INFO Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:151) [2022-01-28 10:53:15,687] INFO Stopping KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:208) [2022-01-28 10:53:15,688] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204) [2022-01-28 10:53:15,690] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,690] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,690] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,691] INFO App info kafka.producer for producer-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,692] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,692] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,692] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,694] INFO App info kafka.consumer for consumer-connect-cluster-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,695] INFO Stopped KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:237) [2022-01-28 10:53:15,695] INFO Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:159) [2022-01-28 10:53:15,695] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,695] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,695] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,695] INFO App info kafka.connect for 127.0.1.1:8083 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,695] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:226) [2022-01-28 10:53:15,697] INFO App info kafka.admin.client for adminclient-8 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-01-28 10:53:15,700] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-01-28 10:53:15,700] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-01-28 10:53:15,701] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-01-28 10:53:15,701] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:321) [2022-01-28 10:53:15,718] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:738) [2022-01-28 10:53:15,718] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72)