둘다 어쨌든 서버니까 http에서 배웠던 것 처럼 클라이언트랑 정보를 주고받을 수 있고, 만약에 was랑 웹서버를 둘다 쓰게 되는 경우라면(웹서버에 정적, was에 동적 데이터) 웹서버는 서버이자 동시에 was랑 통신하는 클라이언트도 되는 게 맞나요 ??

localhost:8083/connectors를 쳤을 경우에 발생합니다..\bin\windows\connect-distributed.bat .\etc\kafka\connect-distributed.properties[2022-12-03 17:23:18,033] INFO WorkerInfo values: jvm.args = -Xmx256M, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=C:\confluent-7.2.2/logs, -Dlog4j.configuration=file:C:\confluent-7.2.2/etc/kafka/connect-log4j.properties jvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 18.0.1.1, 18.0.1.1+2-6 jvm.classpath = C:\confluent-7.2.2\share\java\kafka\activation-1.1.1.jar;C:\confluent-7.2.2\share\java\kafka\aopalliance-repackaged-2.6.1.jar;C:\confluent-7.2.2\share\java\kafka\argparse4j-0.7.0.jar;C:\confluent-7.2.2\share\java\kafka\audience-annotations-0.5.0.jar;C:\confluent-7.2.2\share\java\kafka\commons-cli-1.4.jar;C:\confluent-7.2.2\share\java\kafka\commons-lang3-3.8.1.jar;C:\confluent-7.2.2\share\java\kafka\connect-api-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-basic-auth-extension-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-json-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-mirror-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-mirror-client-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-runtime-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\connect-transforms-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\hk2-api-2.6.1.jar;C:\confluent-7.2.2\share\java\kafka\hk2-locator-2.6.1.jar;C:\confluent-7.2.2\share\java\kafka\hk2-utils-2.6.1.jar;C:\confluent-7.2.2\share\java\kafka\jackson-annotations-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-core-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-databind-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-dataformat-csv-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-datatype-jdk8-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-jaxrs-base-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-jaxrs-json-provider-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-module-jaxb-annotations-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jackson-module-scala_2.13-2.13.3.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.activation-api-1.2.2.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.annotation-api-1.3.5.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.inject-2.6.1.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.validation-api-2.0.2.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.ws.rs-api-2.1.6.jar;C:\confluent-7.2.2\share\java\kafka\jakarta.xml.bind-api-2.3.3.jar;C:\confluent-7.2.2\share\java\kafka\javassist-3.27.0-GA.jar;C:\confluent-7.2.2\share\java\kafka\javax.servlet-api-3.1.0.jar;C:\confluent-7.2.2\share\java\kafka\javax.ws.rs-api-2.1.1.jar;C:\confluent-7.2.2\share\java\kafka\jaxb-api-2.3.0.jar;C:\confluent-7.2.2\share\java\kafka\jersey-client-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jersey-common-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jersey-container-servlet-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jersey-container-servlet-core-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jersey-hk2-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jersey-server-2.34.jar;C:\confluent-7.2.2\share\java\kafka\jetty-client-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-continuation-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-http-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-io-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-security-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-server-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-servlet-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-servlets-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-util-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jetty-util-ajax-9.4.48.v20220622.jar;C:\confluent-7.2.2\share\java\kafka\jline-3.21.0.jar;C:\confluent-7.2.2\share\java\kafka\jopt-simple-5.0.4.jar;C:\confluent-7.2.2\share\java\kafka\jose4j-0.7.9.jar;C:\confluent-7.2.2\share\java\kafka\kafka-clients-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-log4j-appender-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-metadata-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-raft-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-server-common-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-shell-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-storage-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-storage-api-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-streams-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-streams-examples-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-streams-scala_2.13-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-streams-test-utils-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka-tools-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\kafka.jar;C:\confluent-7.2.2\share\java\kafka\kafka_2.13-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\lz4-java-1.8.0.jar;C:\confluent-7.2.2\share\java\kafka\maven-artifact-3.8.4.jar;C:\confluent-7.2.2\share\java\kafka\metrics-core-2.2.0.jar;C:\confluent-7.2.2\share\java\kafka\metrics-core-4.1.12.1.jar;C:\confluent-7.2.2\share\java\kafka\mysql-connector-java-8.0.28.jar;C:\confluent-7.2.2\share\java\kafka\netty-buffer-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-codec-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-common-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-handler-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-resolver-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-transport-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-transport-classes-epoll-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-transport-native-epoll-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\netty-transport-native-unix-common-4.1.79.Final.jar;C:\confluent-7.2.2\share\java\kafka\osgi-resource-locator-1.0.3.jar;C:\confluent-7.2.2\share\java\kafka\paranamer-2.8.jar;C:\confluent-7.2.2\share\java\kafka\plexus-utils-3.3.0.jar;C:\confluent-7.2.2\share\java\kafka\reflections-0.9.12.jar;C:\confluent-7.2.2\share\java\kafka\reload4j-1.2.19.jar;C:\confluent-7.2.2\share\java\kafka\rocksdbjni-6.29.4.1.jar;C:\confluent-7.2.2\share\java\kafka\scala-collection-compat_2.13-2.6.0.jar;C:\confluent-7.2.2\share\java\kafka\scala-java8-compat_2.13-1.0.2.jar;C:\confluent-7.2.2\share\java\kafka\scala-library-2.13.8.jar;C:\confluent-7.2.2\share\java\kafka\scala-logging_2.13-3.9.4.jar;C:\confluent-7.2.2\share\java\kafka\scala-reflect-2.13.8.jar;C:\confluent-7.2.2\share\java\kafka\slf4j-api-1.7.36.jar;C:\confluent-7.2.2\share\java\kafka\slf4j-reload4j-1.7.36.jar;C:\confluent-7.2.2\share\java\kafka\snappy-java-1.1.8.4.jar;C:\confluent-7.2.2\share\java\kafka\trogdor-7.2.2-ccs.jar;C:\confluent-7.2.2\share\java\kafka\zookeeper-3.6.3.jar;C:\confluent-7.2.2\share\java\kafka\zookeeper-jute-3.6.3.jar;C:\confluent-7.2.2\share\java\kafka\zstd-jni-1.5.2-1.jar os.spec = Windows 11, amd64, 10.0 os.vcpus = 8 (org.apache.kafka.connect.runtime.WorkerInfo:71)[2022-12-03 17:23:18,033] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:92)[2022-12-03 17:23:18,050] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\checker-qual-3.5.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,114] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/checker-qual-3.5.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,114] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:18,114] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:18,114] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:18,130] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\common-utils-6.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,210] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/common-utils-6.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,210] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\jtds-1.3.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,242] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/jtds-1.3.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,242] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\kafka-connect-jdbc-10.6.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,274] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/kafka-connect-jdbc-10.6.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,274] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:18,274] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:18,274] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\mssql-jdbc-8.4.1.jre8.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,420] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/mssql-jdbc-8.4.1.jre8.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,440] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\mysql-connector-java-8.0.28.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,547] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/mysql-connector-java-8.0.28.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,547] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\ojdbc8-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,721] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/ojdbc8-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,738] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\ons-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,754] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/ons-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,754] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\oraclepki-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,786] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/oraclepki-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,786] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\orai18n-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,802] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/orai18n-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,802] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\osdt_cert-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,837] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/osdt_cert-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,837] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\osdt_core-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,869] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/osdt_core-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,869] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\postgresql-42.3.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:18,901] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/postgresql-42.3.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:18,917] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\simplefan-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,060] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/simplefan-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:19,060] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\slf4j-api-1.7.36.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,186] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/slf4j-api-1.7.36.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:19,186] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\sqlite-jdbc-3.25.2.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,203] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/sqlite-jdbc-3.25.2.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:19,203] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\ucp-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,270] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/ucp-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:19,270] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\xdb-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,303] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/xdb-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:19,303] INFO Loading plugin from: C:\confluentinc-kafka-connect-jdbc-10.6.0\lib\xmlparserv2-19.7.0.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:277)[2022-12-03 17:23:19,390] INFO Registered loader: PluginClassLoader{pluginLocation=file:/C:/confluentinc-kafka-connect-jdbc-10.6.0/lib/xmlparserv2-19.7.0.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:20,049] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@27c170f0 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:299)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,049] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,064] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,064] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,065] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:230)[2022-12-03 17:23:20,069] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:473)[2022-12-03 17:23:20,069] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,069] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:476)[2022-12-03 17:23:20,103] 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 = All 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] key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] 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 = [C:\confluentinc-kafka-connect-jdbc-10.6.0\lib] 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 = [] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,103] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,119] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,176] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,176] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,182] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,182] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,182] INFO Kafka startTimeMs: 1670055800182 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,362] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,375] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,380] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,380] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,381] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,382] INFO Logging initialized @5709ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:170)[2022-12-03 17:23:20,414] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:117)[2022-12-03 17:23:20,414] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:188)[2022-12-03 17:23:20,414] INFO jetty-9.4.48.v20220622; built: 2022-06-21T20:42:25.880Z; git: 6b67c5719d1f4371b33655ff2d047d24e171e49a; jvm 18.0.1.1+2-6 (org.eclipse.jetty.server.Server:375)[2022-12-03 17:23:20,435] INFO Started http_8083@3eee3e2b{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:333)[2022-12-03 17:23:20,435] INFO Started @5758ms (org.eclipse.jetty.server.Server:415)[2022-12-03 17:23:20,435] INFO Advertised URI: http://192.168.43.212:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)[2022-12-03 17:23:20,451] INFO REST server listening at http://192.168.43.212:8083/, advertising URL http://192.168.43.212:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:203)[2022-12-03 17:23:20,451] INFO Advertised URI: http://192.168.43.212:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)[2022-12-03 17:23:20,451] INFO REST admin endpoints at http://192.168.43.212:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:204)[2022-12-03 17:23:20,451] INFO Advertised URI: http://192.168.43.212:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:355)[2022-12-03 17:23:20,451] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,451] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,451] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,451] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,451] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,451] INFO Kafka startTimeMs: 1670055800451 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,475] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,480] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,482] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,482] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,482] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,484] INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy:44)[2022-12-03 17:23:20,484] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,484] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,484] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,484] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,484] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,484] INFO Kafka startTimeMs: 1670055800484 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,504] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,507] INFO App info kafka.admin.client for adminclient-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,509] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,509] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,509] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,513] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,513] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,513] INFO Kafka startTimeMs: 1670055800513 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,569] INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:376)[2022-12-03 17:23:20,586] INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig:376)[2022-12-03 17:23:20,586] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,586] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,586] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,586] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,586] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,586] INFO Kafka startTimeMs: 1670055800586 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,586] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,600] INFO App info kafka.admin.client for adminclient-4 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,603] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,603] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,603] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,605] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,605] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,605] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,605] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,605] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,605] INFO Kafka startTimeMs: 1670055800605 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,620] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,622] INFO App info kafka.admin.client for adminclient-5 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,623] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,623] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,624] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,624] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,624] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,624] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,624] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,624] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,624] INFO Kafka startTimeMs: 1670055800624 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,624] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,639] INFO App info kafka.admin.client for adminclient-6 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,639] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,639] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,640] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,642] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:51)[2022-12-03 17:23:20,642] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,642] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,642] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,642] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,642] INFO Kafka startTimeMs: 1670055800642 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,658] INFO Kafka cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.connect.util.ConnectUtils:67)[2022-12-03 17:23:20,661] INFO App info kafka.admin.client for adminclient-7 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2022-12-03 17:23:20,662] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)[2022-12-03 17:23:20,662] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)[2022-12-03 17:23:20,662] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)[2022-12-03 17:23:20,663] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,663] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,663] INFO Kafka startTimeMs: 1670055800663 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,663] INFO Kafka Connect distributed worker initialization took 2628ms (org.apache.kafka.connect.cli.ConnectDistributed:138)[2022-12-03 17:23:20,663] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51)[2022-12-03 17:23:20,663] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:208)[2022-12-03 17:23:20,663] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:318)[2022-12-03 17:23:20,663] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:184)[2022-12-03 17:23:20,663] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:150)[2022-12-03 17:23:20,663] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:166)[2022-12-03 17:23:20,679] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:20,679] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)[2022-12-03 17:23:20,679] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:20,679] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:20,679] INFO Kafka startTimeMs: 1670055800679 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:20,691] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:225)[2022-12-03 17:23:20,737] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:334)[2022-12-03 17:23:20,737] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:339)[2022-12-03 17:23:20,737] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:132)12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntimeWARNING: 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.12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntimeWARNING: 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.12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntimeWARNING: 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.12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntimeWARNING: 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.12월 03, 2022 5:23:21 오후 org.glassfish.jersey.internal.Errors logErrorsWARNING: 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-12-03 17:23:21,074] INFO Started o.e.j.s.ServletContextHandler@75ae4a1f{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:921)[2022-12-03 17:23:21,074] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:303)[2022-12-03 17:23:21,074] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)[2022-12-03 17:23:21,186] INFO Created topic (name=connect-offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:389)[2022-12-03 17:23:21,190] 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 = [] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:21,190] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,190] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,190] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,190] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,208] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,203] INFO [Producer clientId=producer-1] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,208] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,209] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,209] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,209] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,209] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,209] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,209] INFO Kafka startTimeMs: 1670055801209 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,209] 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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 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:376)[2022-12-03 17:23:21,225] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,225] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,225] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,225] INFO Kafka startTimeMs: 1670055801225 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,225] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,241] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Subscribed to partition(s): connect-offsets-0, connect-offsets-5, connect-offsets-10, connect-offsets-20, connect-offsets-15, connect-offsets-9, connect-offsets-11, connect-offsets-4, connect-offsets-16, connect-offsets-17, connect-offsets-3, connect-offsets-24, connect-offsets-23, connect-offsets-13, connect-offsets-18, connect-offsets-22, connect-offsets-8, connect-offsets-2, connect-offsets-12, connect-offsets-19, connect-offsets-14, connect-offsets-1, connect-offsets-6, connect-offsets-7, connect-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,241] 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:642)[2022-12-03 17:23:21,257] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-0 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,257] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-5 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,257] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-10 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-20 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-15 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-9 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-11 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-4 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-16 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,269] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-17 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,272] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-3 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,274] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-24 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,277] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-23 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-13 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-18 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-22 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-8 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-2 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-12 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-19 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-14 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-1 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-6 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-7 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] INFO [Consumer clientId=consumer-connect-cluster-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-21 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,278] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,293] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,294] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,294] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,294] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,294] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,294] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:206)[2022-12-03 17:23:21,294] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:208)[2022-12-03 17:23:21,294] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:152)[2022-12-03 17:23:21,294] INFO Worker started (org.apache.kafka.connect.runtime.Worker:191)[2022-12-03 17:23:21,294] INFO Starting KafkaBasedLog with topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:166)[2022-12-03 17:23:21,369] INFO Created topic (name=connect-status, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:389)[2022-12-03 17:23:21,369] 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 = [] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:21,372] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,372] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,381] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,382] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,381] INFO [Producer clientId=producer-2] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,383] INFO Kafka startTimeMs: 1670055801381 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,383] 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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 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:376)[2022-12-03 17:23:21,383] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,383] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,383] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,383] INFO Kafka startTimeMs: 1670055801383 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,399] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,402] 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:1123)[2022-12-03 17:23:21,402] 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:642)[2022-12-03 17:23:21,402] 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:642)[2022-12-03 17:23:21,402] 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:642)[2022-12-03 17:23:21,403] 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:642)[2022-12-03 17:23:21,403] 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:642)[2022-12-03 17:23:21,410] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,410] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,410] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,410] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,410] INFO [Consumer clientId=consumer-connect-cluster-2, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,410] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,410] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,410] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,410] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,410] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,410] INFO Finished reading KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:206)[2022-12-03 17:23:21,410] INFO Started KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:208)[2022-12-03 17:23:21,410] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:291)[2022-12-03 17:23:21,410] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:166)[2022-12-03 17:23:21,447] INFO Created topic (name=connect-configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at localhost:9092 (org.apache.kafka.connect.util.TopicAdmin:389)[2022-12-03 17:23:21,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 = producer-3 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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:376)[2022-12-03 17:23:21,447] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,447] INFO [Producer clientId=producer-3] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,447] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:384)[2022-12-03 17:23:21,459] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,459] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,459] INFO Kafka startTimeMs: 1670055801459 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,459] 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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 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:376)[2022-12-03 17:23:21,459] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:384)[2022-12-03 17:23:21,459] INFO Kafka version: 7.2.2-ccs (org.apache.kafka.common.utils.AppInfoParser:119)[2022-12-03 17:23:21,459] INFO Kafka commitId: b1f098d4b86fb0e9bc6cc86da16ad16e8cd26ebd (org.apache.kafka.common.utils.AppInfoParser:120)[2022-12-03 17:23:21,459] INFO Kafka startTimeMs: 1670055801459 (org.apache.kafka.common.utils.AppInfoParser:121)[2022-12-03 17:23:21,459] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:21,469] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)[2022-12-03 17:23:21,470] 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:642)[2022-12-03 17:23:21,474] INFO [Consumer clientId=consumer-connect-cluster-3, groupId=connect-cluster] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to wzucMnPJSWa92v9021fiWg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] 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[dongjun:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)[2022-12-03 17:23:21,474] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:206)[2022-12-03 17:23:21,474] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:208)[2022-12-03 17:23:21,474] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:306)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:322)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-0 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-5 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-10 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-20 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-15 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-9 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-11 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-4 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-16 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-17 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,474] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-3 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,487] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-24 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,488] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-23 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,490] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-13 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-18 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-22 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-8 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-2 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-12 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-19 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,493] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-14 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,496] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-1 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,496] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-6 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,496] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-7 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,497] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-offsets-21 to 0 since the associated topicId changed from null to x-Icc_YwRL6lK6kjGAUbdg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,497] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,497] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,497] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,497] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,498] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to ym5u2s8ySty4G9yhuA_gcQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,498] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to wzucMnPJSWa92v9021fiWg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:21,499] INFO [Worker clientId=connect-1, groupId=connect-cluster] Cluster ID: PMGnJFVHRbqJ0BHd__SNpg (org.apache.kafka.clients.Metadata:287)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-0 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-10 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-20 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-40 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-30 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-9 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-11 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-31 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-39 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-13 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-18 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-22 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-8 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-32 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-43 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-29 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-34 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-1 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-6 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-41 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-27 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-48 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-5 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-15 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-35 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-25 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-46 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-26 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-36 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-44 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-16 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-37 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-17 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-45 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-3 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,120] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-24 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-38 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-33 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-23 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-28 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-2 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-12 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-19 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-14 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-4 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-47 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-49 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-42 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-7 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Resetting the last seen epoch of partition __consumer_offsets-21 to 0 since the associated topicId changed from null to rqQbN08wSU-9QDn4uqdIdQ (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Discovered group coordinator dongjun:9092 (id: 2147483647 rack: null) (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:897)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:228)[2022-12-03 17:23:22,136] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:566)[2022-12-03 17:23:22,152] INFO [Worker clientId=connect-1, groupId=connect-cluster] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:1063)[2022-12-03 17:23:22,152] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:566)[2022-12-03 17:23:22,168] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:627)[2022-12-03 17:23:22,202] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:802)[2022-12-03 17:23:22,202] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', leaderUrl='http://192.168.43.212:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1853)[2022-12-03 17:23:22,202] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1378)[2022-12-03 17:23:22,202] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1406)[2022-12-03 17:23:22,227] INFO [Producer clientId=producer-3] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to wzucMnPJSWa92v9021fiWg (org.apache.kafka.clients.Metadata:402)[2022-12-03 17:23:22,245] INFO [Worker clientId=connect-1, groupId=connect-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1721)[2022-12-03 17:23:45,624] INFO JdbcSourceConnectorConfig values: batch.max.rows = 100 catalog.pattern = null connection.attempts = 3 connection.backoff.ms = 10000 connection.password = [hidden] connection.url = jdbc:mysql://mysql-sink:3306/mydb connection.user = root db.timezone = UTC dialect.name = incrementing.column.name = id mode = incrementing numeric.mapping = null numeric.precision.mapping = false poll.interval.ms = 5000 query = query.retry.attempts = -1 query.suffix = quote.sql.identifiers = ALWAYS schema.pattern = null table.blacklist = [] table.monitoring.startup.polling.limit.ms = 10000 table.poll.interval.ms = 60000 table.types = [TABLE] table.whitelist = [user_mydb] timestamp.column.name = [] timestamp.delay.interval.ms = 0 timestamp.granularity = connect_logical timestamp.initial = null topic.prefix = my_topic_ transaction.isolation.mode = DEFAULT validate.non.null = true (io.confluent.connect.jdbc.source.JdbcSourceConnectorConfig:376)[2022-12-03 17:23:45,626] INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig:376)[2022-12-03 17:23:45,636] INFO [Worker clientId=connect-1, groupId=connect-cluster] Connector my-source-connect config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1677)[2022-12-03 17:23:45,637] INFO [Worker clientId=connect-1, groupId=connect-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:228)[2022-12-03 17:23:45,637] INFO [Worker clientId=connect-1, groupId=connect-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:566)[2022-12-03 17:23:45,640] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully joined group with generation Generation{generationId=2, memberId='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:627)[2022-12-03 17:23:45,645] INFO [Worker clientId=connect-1, groupId=connect-cluster] Successfully synced group in generation Generation{generationId=2, memberId='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:802)[2022-12-03 17:23:45,646] INFO [Worker clientId=connect-1, groupId=connect-cluster] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-a29b010d-d427-4726-a713-0f887e1e81c1', leaderUrl='http://192.168.43.212:8083/', offset=2, connectorIds=[my-source-connect], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1853)[2022-12-03 17:23:45,647] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connectors and tasks using config offset 2 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1378)[2022-12-03 17:23:45,649] INFO [Worker clientId=connect-1, groupId=connect-cluster] Starting connector my-source-connect (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1455)[2022-12-03 17:23:45,651] INFO [my-source-connect|worker] Creating connector my-source-connect of type io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:264)[2022-12-03 17:23:45,652] INFO [my-source-connect|worker] SourceConnectorConfig values: config.action.reload = restart connector.class = io.confluent.connect.jdbc.JdbcSourceConnector 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 = my-source-connect predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig:376)[2022-12-03 17:23:45,652] INFO [my-source-connect|worker] EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.confluent.connect.jdbc.JdbcSourceConnector 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 = my-source-connect predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)[2022-12-03 17:23:45,655] INFO [my-source-connect|worker] Instantiated connector my-source-connect with version 10.6.0 of type class io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:274)[2022-12-03 17:23:45,655] INFO [my-source-connect|worker] Finished creating connector my-source-connect (org.apache.kafka.connect.runtime.Worker:299)[2022-12-03 17:23:45,655] INFO [Worker clientId=connect-1, groupId=connect-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1406)[2022-12-03 17:23:45,656] INFO [my-source-connect|worker] Starting JDBC Source Connector (io.confluent.connect.jdbc.JdbcSourceConnector:71)[2022-12-03 17:23:45,656] INFO [my-source-connect|worker] JdbcSourceConnectorConfig values: batch.max.rows = 100 catalog.pattern = null connection.attempts = 3 connection.backoff.ms = 10000 connection.password = [hidden] connection.url = jdbc:mysql://mysql-sink:3306/mydb connection.user = root db.timezone = UTC dialect.name = incrementing.column.name = id mode = incrementing numeric.mapping = null numeric.precision.mapping = false poll.interval.ms = 5000 query = query.retry.attempts = -1 query.suffix = quote.sql.identifiers = ALWAYS schema.pattern = null table.blacklist = [] table.monitoring.startup.polling.limit.ms = 10000 table.poll.interval.ms = 60000 table.types = [TABLE] table.whitelist = [user_mydb] timestamp.column.name = [] timestamp.delay.interval.ms = 0 timestamp.granularity = connect_logical timestamp.initial = null topic.prefix = my_topic_ transaction.isolation.mode = DEFAULT validate.non.null = true (io.confluent.connect.jdbc.source.JdbcSourceConnectorConfig:376)[2022-12-03 17:23:45,659] INFO [my-source-connect|worker] Attempting to open connection #1 to MySql (io.confluent.connect.jdbc.util.CachedConnectionProvider:79)[2022-12-03 17:23:48,015] INFO [my-source-connect|worker] Unable to connect to database on attempt 1/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider:86)com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failureThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64) at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:829) at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:449) at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:242) at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:683) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:191) at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.getConnection(GenericDatabaseDialect.java:250) at io.confluent.connect.jdbc.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:80) at io.confluent.connect.jdbc.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:52) at io.confluent.connect.jdbc.JdbcSourceConnector.start(JdbcSourceConnector.java:94) at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:184) at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:209) at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:348) at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:331) at org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:140) at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:117) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833)Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications link failureThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:67) at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:499) at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:483) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151) at com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167) at com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89) at com.mysql.cj.NativeSession.connect(NativeSession.java:120) at com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:949) at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:819) ... 20 moreCaused by: java.net.UnknownHostException: 알려진 호스트가 없습니다 (mysql-sink) at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Inet6AddressImpl.java:52) at java.base/java.net.InetAddress$PlatformResolver.lookupByName(InetAddress.java:1048) at java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1638) at java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:997) at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1628) at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1494) at com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:133) at com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63) ... 23 more[2022-12-03 17:23:58,026] INFO [my-source-connect|worker] Attempting to open connection #2 to MySql (io.confluent.connect.jdbc.util.CachedConnectionProvider:79)[2022-12-03 17:24:00,300] INFO [my-source-connect|worker] Unable to connect to database on attempt 2/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider:86)com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failureThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64) at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:829) at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:449) at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:242) at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:683) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:191) at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.getConnection(GenericDatabaseDialect.java:250) at io.confluent.connect.jdbc.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:80) at io.confluent.connect.jdbc.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:52) at io.confluent.connect.jdbc.JdbcSourceConnector.start(JdbcSourceConnector.java:94) at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:184) at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:209) at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:348) at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:331) at org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:140) at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:117) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833)Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications link failureThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:67) at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:499) at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:483) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105) at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151) at com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167) at com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89) at com.mysql.cj.NativeSession.connect(NativeSession.java:120) at com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:949) at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:819) ... 20 moreCaused by: java.net.UnknownHostException: 알려진 호스트가 없습니다 (mysql-sink) at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Inet6AddressImpl.java:52) at java.base/java.net.InetAddress$PlatformResolver.lookupByName(InetAddress.java:1048) at java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1638) at java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:997) at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1628) at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1494) at com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:133) at com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63) ... 23 moreconnect-distributed## # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. ## # This file contains some of the configurations for the Kafka Connect distributed worker. This file is intended # to be used with the examples, and some settings may differ from those used in a production system, especially # the `bootstrap.servers` and those specifying replication factors. # A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. bootstrap.servers=localhost:9092 # unique name for the cluster, used in forming the Connect cluster group. Note that this must not conflict with consumer group IDs group.id=connect-cluster # The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will # need to configure these based on the format they want their data in when loaded from or stored into Kafka key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka.connect.json.JsonConverter # Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply # it to key.converter.schemas.enable=true value.converter.schemas.enable=true # Topic to use for storing offsets. This topic should have many partitions and be replicated and compacted. # Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create # the topic before starting Kafka Connect if a specific topic configuration is needed. # Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value. # Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able # to run this example on a single-broker cluster and so here we instead set the replication factor to 1. offset.storage.topic=connect-offsets offset.storage.replication.factor=1 #offset.storage.partitions=25 # Topic to use for storing connector and task configurations; note that this should be a single partition, highly replicated, # and compacted topic. Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create # the topic before starting Kafka Connect if a specific topic configuration is needed. # Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value. # Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able # to run this example on a single-broker cluster and so here we instead set the replication factor to 1. config.storage.topic=connect-configs config.storage.replication.factor=1 # Topic to use for storing statuses. This topic can have multiple partitions and should be replicated and compacted. # Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create # the topic before starting Kafka Connect if a specific topic configuration is needed. # Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value. # Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able # to run this example on a single-broker cluster and so here we instead set the replication factor to 1. status.storage.topic=connect-status status.storage.replication.factor=1 #status.storage.partitions=5 # Flush much faster than normal, which is useful for testing/debugging offset.flush.interval.ms=10000 # List of comma-separated URIs the REST API will listen on. The supported protocols are HTTP and HTTPS. # Specify hostname as 0.0.0.0 to bind to all interfaces. # Leave hostname empty to bind to default interface. # Examples of legal listener lists: HTTP://myhost:8083,HTTPS://myhost:8084" #listeners=HTTP://:8083 # The Hostname & Port that will be given out to other workers to connect to i.e. URLs that are routable from other servers. # If not set, it uses the value for "listeners" if configured. #rest.advertised.host.name= #rest.advertised.port= #rest.advertised.listener= # Set to a list of filesystem paths separated by commas (,) to enable class loading isolation for plugins # (connectors, converters, transformations). The list should consist of top level directories that include # any combination of: # a) directories immediately containing jars with plugins and their dependencies # b) uber-jars with plugins and their dependencies # c) directories immediately containing the package directory structure of classes of plugins and their dependencies # Examples: # plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors, # plugin.path=/usr/share/java plugin.path=\C:\\confluentinc-kafka-connect-jdbc-10.6.0\\libconfluentinc-kafka-connect-jdbc-10.6.0\lib 밑에 mysql-connector-java-8.0.29 해당하는 파일을 넣었습니다.

 안녕하세요,firebase 에서 앱과 모듈수준의 코드를 gradle 파일에 복사해 놓고 빌드하니 에러가 발생합니다. arctic fox 버전으로 바구어서 설치하였습니다. 그래도 안되네요.어떻게 해야할까요?  org.gradle.api.GradleScriptException: A problem occurred evaluating project ':app'. at org.gradle.groovy.scripts.internal.DefaultScriptRunnerFactory$ScriptRunnerImpl.run(DefaultScriptRunnerFactory.java:93) at

HW 가속기가 연속으로 동작한다고 할 때,node값은 정해진 상태고,Weight 값이 변경되면서 동작될테니bram0에 데이터 로딩하는 시간을 제외하면SW 연산보다 HW 연산이 더 빨랐음을 확인할 수 있다고 하셨습니다!! 하지만 처음에 FC layer에 대해 설명해주실 때, deep learning의 예시로 이미지를 특정 동물,사물(ex. cat, dog, hat 등)으로 분류하는 기술로 들어주셨었습니다. Q. 그렇다면 이미 완성되어 있는 structure(= weight 고정)에 들어가는 입력(= 이미지 = input node value)만 바뀌게 되는 것이 아닌가요? 강의 너무 잘 듣고 있습니다!! 감사합니다..

Model model 은 @GetMapping 에다가만 적용하나요?여기서 BookForm은 DTO처럼 사용된건데, 꼭 model.attribute("form",new BookForm())처럼 명시해줘야하나요? 

template에서 template <typename T, typename Container = std::vector<T>, typename Predicate = std::less<T>> 이렇게 정의 해주시고 클레스 내부에서 Container _heap = {};Predicate _predicate = {};이런식으로 빈객체를 만들어 주셨다고 하셨는데 저는  template에서 typename Predicate는 std::less<T>를 Predicate로 그냥 정의한 것이고,내가 새롭게 정의한 자료형? 이기때문에Predicate(자료형) predicate = {} (중괄호 초기화로 기본생성자 호출하여); => Predicate라는 자료형을 가지는 변수이름이 _predicate인 객체를 만들었다는 뜻인가요??

r2songhae@gmail.com 으로 강의자료 부탁드립니다. 감사합니다.

 새로운 엔티티를 구별하는 방법에 대해 강의를 듣다가 기존 영속성 엔티티에 비영속성 엔티티를 추가하고 CascadeType.ALL을 통해 비영속성 엔티티를 저장할 때비영속성 엔티티가 기본 키를 직접 할당하는 전략을 사용하면 의도하지 않은 merge가 발생할 것 같아서 테스트를 진행하고 있습니다.  추가적으로 .. Team 엔티티를 저장한 이후 새로운 Member 엔티티를 추가하는 과정에서 @Rollback(value=false)를 주지않으면 Member 엔티티의 insert문이 발생하지 않아서 이 부분도 추가적으로 궁금합니다. @ToString @Getter @Entity @NoArgsConstructor(access = AccessLevel.PROTECTED) public class Team { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; @OneToMany(mappedBy = "team", cascade = CascadeType.ALL) private List<Member> members = new ArrayList<>(); private String name; public void addMember(Member member) { member.setTeam(this); members.add(member); } @Builder private Team(String name) { this.name = name; } } @ToString(exclude = "team") @Getter @Setter @Entity @NoArgsConstructor(access = AccessLevel.PROTECTED) public class Member extends BaseEntity{ @Id private Long id; private String username; private Integer age; @ManyToOne(fetch = FetchType.LAZY) @JoinColumn(name = "team_id") private Team team; @Builder private Member(Long id,String username, Integer age, Team team) { this.id = id; this.username = username; this.age = age; this.team = team; } } 테스트 코드는 다음과 같습니다. @SpringBootTest class TeamJpaRepositoryTest { @Autowired private TeamJpaRepository teamJpaRepository; @Autowired private EntityManager em; @BeforeEach void beforeEach() { Team aTeam = Team.builder() .name("A Team") .build(); teamJpaRepository.save(aTeam); em.clear(); } @Test @Transactional public void saveMember() throws Exception { //given Member userA = Member.builder() .id(10L) .age(10) .username("user A") .build(); //when Team savedTeam = teamJpaRepository.findByName("A Team"); savedTeam.addMember(userA); //then } }  왜 savedTeam에 대해 변경 감지에 대해 @Rollback(value=fasle) 어노테이션이 없으면 Member insert문이 발생하지 않는지 궁금합니다.스프링 데이터 JPA의 쿼리 메소드의 구현체가 @Transaction(readOnly = true)라고 해도 최초 트랜잭션이 readOnly 옵션이 false이기 때문에 트랜잭션 전파의 문제는 아닌 것 같아서요.@Rollback 옵션을 주었을 때 로그는 다음과 같습니다. 처음에 궁금했던 Team 엔티티에 새로운 Member 엔티티를 직접 기본 키를 할당하여 저장할 때해당 로그를 보면 merge가 발생하지 않는 것 같습니다.Persistable 인터페이스의 isNew 메소드를 오버 라이드하지 않았는데 말이죠.이 부분에 대해서 궁금합니다.plugins { id 'java' id 'org.springframework.boot' version '2.7.5' id 'io.spring.dependency-management' version '1.0.15.RELEASE' }

안녕하세요.[22년 추가] PR이 안올라오는 error 관련 강의를 시청하면서 블로그 생성 과정을 따라했습니다.그런데 Action, CI 목록의 Merge pull request #1에서 jekyll build가 실패합니다.어떻게 해결해야 하나요.. 방법을 모르겠습니다. 

안녕하세요?파이어베이스 리얼타임 데이터베이스 저장하기 부분에서 저장하기 버튼을 누르면 날짜와 메모를 리얼타임 데이터 베이스에 저장하도록 하기 위해 DataModel을 따로 만드셨는데 이 부분이 뷰바인딩 개념과 비슷한 부분으로 볼 수 있을까요??

const int MILLS = 1000000;int main(){ DWORD dwStart1 = GetTickCount(); for (int i = 0; i <= MILLS; ++i) cout << "h" << '\n'; DWORD dwEnd1 = GetTickCount(); DWORD dwStart2 = GetTickCount(); for (int i = 0; i <= MILLS; ++i) cout << "h\n"; DWORD dwEnd2 = GetTickCount(); DWORD dwStart3 = GetTickCount(); for (int i = 0; i <= MILLS; ++i) cout << "h" << endl; DWORD dwEnd3 = GetTickCount(); cout << dwStart1 << ' ' << dwEnd1 << ' ' << dwEnd1 - dwStart1 << '\n'; cout << dwStart2 << ' ' << dwEnd2 << ' ' << dwEnd2 - dwStart2 << '\n'; cout << dwStart3 << ' ' << dwEnd3 << ' ' << dwEnd3 - dwStart3 << '\n';} 갑자기 궁금해서 endl 이랑 \n 속도 차이 확인해보고자 어셈블리어 확인하고 결과 값도 확인했습니다. 2번 결과가 왜 빠른지는 어셈블리어 확인하면서 << 연산자 때문이라는 것도 알았습니다. 최종적으로 1번과 3번이 큰 차이는 안나지만 대체로 1번이 더 느리던데 왜 그런가요? 검색해본 결과는 flush 차이로 \n이 더 빠르다고 하지만 반대의 결과가 나와서 궁금합니다. (어셈블리어로 확인해보려 했으나 ??로 채워진 부분도 있어 알아보기 어렵고 같은 for문에서도 어셈블리어가 다르게 적용 돼 있습니다.

안녕하세요! 최근에는 모바일 프레임을 아이폰 14프로로 많이 진행하는거같은데 이 경우에는 컬럼 수와 사이즈 및 간격을 어떻게 잡아야 좋을까요?

https://learn.microsoft.com/ko-kr/windows-server/administration/openssh/openssh_install_firstuse 먼저 로컬 피씨에서 위처럼 진행해주시면 됩니다~

nodejs는 route, controller, service, repository, entity로 하면 중복 없이 잘 짤 수 있다고 조언하신 글을 봤습니다.nextjs는 프로젝트 구조를 어떻게 짜야 하나요? 구글링하니까 정말 다양한 방법이 많이 있던데 제로초님은 실무에서 어떻게 짜시는지 궁금합니다.

ubuntu@ip-172-31-37-255:~/react-nodebird/front$ npm run build > react-nodebird-front@1.0.0 build /home/ubuntu/react-nodebird/front > cross-env ANALYZE=true NODE_ENV=production next build Browserslist: caniuse-lite is outdated. Please run: npx browserslist@latest --update-db info - Using external babel configuration from /home/ubuntu/react-nodebird/front/.babelrc Webpack Bundle Analyzer saved report to /home/ubuntu/react-nodebird/front/.next/server/analyze/client.html Webpack Bundle Analyzer saved report to /home/ubuntu/react-nodebird/front/.next/analyze/client.html info - Creating an optimized production build info - Compiled successfully > Build error occurred Error: Build optimization failed: found page without a React Component as default export in pages/about See https://err.sh/vercel/next.js/page-without-valid-component for more info. at build (/home/ubuntu/react-nodebird/front/node_modules/next/dist/build/index.js:21:115) info - Collecting page data .npm ERR! code ELIFECYCLE npm ERR! errno 1 npm ERR! react-nodebird-front@1.0.0 build: cross-env ANALYZE=true NODE_ENV=production next build npm ERR! Exit status 1 npm ERR! npm ERR! Failed at the react-nodebird-front@1.0.0 build script. npm ERR! This is probably not a problem with npm. There is likely additional logging output above. npm ERR! A complete log of this run can be found in: npm ERR! /home/ubuntu/.npm/_logs/2022-12-03T04_13_49_262Z-debug.log 백엔드에서 npm run dev하면 use 80 무슨 오류 떠서 포트번호 85번으로 바꿧어요백엔드쪽 app.js 85번으로 바꾸고vim app.js에서 85번 바꾸고프론트쪽 package.json에서 -p 85로 바꿧어요git status해도 아무것도 안나오고 백엔드 프론트 서버키고 npm run build 하면 오류뜹니다 app.jsfront / package.js

작업형 1유형은 이 강의 토대로 술술 풀었습니다(3번에서 전체전입전출학생수 칼럼 있는 줄도 모르고 1~6학년 더하고 빼고 그랬네요)2유형에서 요 강의 토대로 풀려고 하는데결측치도 없고 이상치도 없는 것 같고.. 느낌이 쎄한게train에 어떤 method를 써도 안되는 겁니다.. rpart glm lm lda randomForest까지..rpart는 너무 오래 걸리고glm이었나 lda는Accuracy Kappa에 NA값이 있다며(?) 오류가 떴습니다음.. 강의에서 배운 건 다 써봤는데 역시 기본 이해가 없어서인지 다른 해결방법이 떠오르지 않더군요..풀이 강의 부탁드리겠습니다 

package kr.bit.mapper;import java.util.List;import kr.bit.entity.Board;//@Mapperpublic interface BoardMapper { public List<Board> getList(); public void insert(Board vo); };강의 잘보고있습니다. 수강하다가 궁금한점이 있어서 질문드립니다. ----> public void insert(Board vo); <----위에 기재한 코드에서 Board vo 이런식으로 처리를 하는데 entity에 @Data 어노테이션 처리를 한 Board.java를 vo의 형태로 insert한다고 생각하면 되는건가요? vo라는 형태로 넣는건지 아니면 vo라는 이름으로 넣는건지 약간 헷갈립니다 ㅠ 입사한지 얼마안되서 spring(EGOV)으로 업무를 보고 있는데 EGOV에서는 VO, DAO로 나누어서 DAO가 MAPPER랑 연결되는? 방식입니다. 선생님 강의에서도 다를것 크게 없긴하죠 BoardMapper.java가 제가 말씀드린 사실상 DAO방식이고 Board.java도 VO의 역할을 하고 있으니까요. 위에 같은 궁금증이 생긴 이유가 평소에 저는 Dao에서 아래와 같은 방식으로 처리했습니다. public void insertWriting(WritngDrwVO writngDrwVO) throws Exception{ insert ("WritngDAO.insertWritingDrw", writngDrwVO);} 코드를 보시면 WritingDrwVO라는 VO 클래스가 생성이 되어있고 public void insertWriting(WritngDrwVO writngDrwVO)라는 코드를 통해 WritngDrwVO를 writngDrwVO라는 이름으로 선언을 하고있고 insert ("WritngDAO.insertWritingDrw", writngDrwVO);} 라는 코드에서 위에서 선언한 WritngDrwVO를 writngDrwVO라는 이름으로 insert한다? 이런식으로 이해를 하고 선생님의 강의를 보니까 위에서 말씀드린 헷갈리는 부분이 나온것 같습니다..... 글이 너무 길었네요 ㅠㅠㅠㅠ 강의 잘보고 있고 스프2탄을 제일 처음 들었는데 완강하고 나프나 스프 올라온거 쭉 완강하도록 하겠습니다. 

안녕하세요. 섹션 9. OAuth 2.0 Client - Social Login (Google, Naver, KaKao) + FormLogin 에서의 User 도메인에 대한 질문입니다. username 에 대한 질문 폼 로그인에 사용되는 계정과 OAuth 2.0 로그인에 사용되는 계정을 추상화하는 과정에서제공자 계정의 (변경가능한) 별명에 해당하는 값을 username으로 받는 것으로 보입니다. 하지만 클라이언트 자체 계정에서의 username 은 고유하기 때문에 Q1) 이를 동일한 속성을 갖도록하는게 맞는지 혹은 해도 무방한지Q2) 이를 별도의 속성으로 받아도 괜찮은지 궁금합니다. (e.g. nickname)    id + username 에 대한 질문"sub" 혹은 "id" 로 매핑되어있는 값을 id라는 필드에 넣도록 구현되어있는데 public class NaverUser extends OAuth2ProviderUser { @Override public String getId() { return (String)getAttributes().get("id"); // ! } public class GoogleUser extends OAuth2ProviderUser { @Override public String getId() { return (String)getAttributes().get("sub"); // ! }네이버 문서에 아래와 같은 내용이 있습니다.위 설명에 따르면 네이버를 기준으로 id가 클라이언트 자체 계정에서의 username 과 동일한 역할을 하는 것으로 보입니다.Q3) 따라서 1번 질문과 반대로 id 필드에 저장되는 값이 오히려 username 에 적합해보이는데 이에 대한 의견을 듣고 싶습니다.   clientId 에 대한 질문 User 클래스에 String ci (clientId) 필드가 포함되어 있는데,Q4) 이는 외부 설정파일로부터 설정하는데 저장해야할 필요가 있나요? 지워도 무방한가요? public class User { private String registrationId; private String id; private String ci; // ! private String username; private String password; private String provider; private String email; private String picture; private List<? extends GrantedAuthority> authorities;   registrationId 에 대한 질문 registrationId 가 provider(google...) 를 의미하는 것으로 보이는데,Q6) FormLogin 클래스에 registrationId, provider 두 필드가 모두 존재합니다. 하나는 지워도 무방한가요? public abstract class OAuth2ProviderUser implements ProviderUser { @Override public String getProvider() { return clientRegistration.getRegistrationId(); // ! }public class FormUser implements ProviderUser { private String registrationId; // ! private String id; private String username; private String password; private String email; private boolean isCertificated; private String provider; // !   

item.getItemName() == null 로 써도 될거 같은데 hasText를 쓴 이유는 뭔가요?

변수에 선언된 값이 변경될때마다 가스비가 추가적으로 발생하나요?