묻고 답해요
131만명의 커뮤니티!! 함께 토론해봐요.
인프런 TOP Writers
-
미해결[리뉴얼] 타입스크립트 올인원 : Part1. 기본 문법편
map 함수 제네릭 분석과정에 대해서 질문드립니다.
안녕하세요. 제로초님 강의 잘 듣고있습니다.map함수를 분석할 때 두번째 제네릭(U)이 map 옆(map<U>)에 또 선언되는 이유에 대해 궁금해서 질문드립니다.일단은 강의를 보면서 변수를 사용하기 위해 변수를 선언한 것처럼map옆에도 제네릭을 추가로 사용하기 위해 선언한거라고 추측해서 이해했는데 이게 맞을까요?콜백함수의 return, map 함수의 전체 return에서만 선언하면 될 것같은데어떤 이유때문에 추가로 map옆(map<U>)에도 제네릭(U)을 사용하는 건가요? // map<U>(callbackfn: (value: T, index: number, array: T[]) => U, thisArg?: any): U[]; map<U>(callbackfn: (value: number, index: number, array: number[]) => string, thisArg?: any): string[]; // map<U> -> why?? [1, 2, 3].map((item) => { item.toString() });
-
미해결우리를 위한 프로그래밍 : 파이썬 중급 (Inflearn Original)
혹시 특정 시간에 특정 코드가 실행되게끔 할 수 있을까요?
예를들면 처음 코드 시작 시점으로부터16분동안 돌아가는 프로그램에서1. 5분후에는 'a' 출력,2. 10분후 'b' 출력3. 15분후 'c' 출력이런식으로 하고 싶습니다..!아래처럼 16분간 계속 while문 돌리면서 굉장히 비효율적이게 할 수는 있을 것 같은데 혹시 좋은 방법이 있을까 해서 여쭤봅니당..ㅎㅎ start_time = datetime.now() after_5min_time = datetime(start_time.year, start_time.month, start_time.day, start_time.hour, start_time.minute + 5, start_time.second) after_10min_time = datetime(start_time.year, start_time.month, start_time.day, start_time.hour, start_time.minute + 10, start_time.second) after_15min_time = datetime(start_time.year, start_time.month, start_time.day, start_time.hour, start_time.minute + 15, start_time.second) interval_list = [after_5min_time, after_10min_time, after_15min_time] end_time = datetime(start_time.year, start_time.month, start_time.day, start_time.hour, start_time.minute + 16, start_time.second) while start_time <= end_time: if datetime.now() == after_5min_time: print('a') elif datetime.now() == after_10min_time: print('b') elif datetime.now() == after_15min_time: print('c')
-
미해결스프링 MVC 1편 - 백엔드 웹 개발 핵심 기술
restAPI를 쓰면 CSR 형태로 데이터를 주고받는건가요?
restAPI를 사용해서 백엔드가 프론트로 json파일만 보내주면 그거가지고 프론트에서 react 써서 데이터를 화면에 보여주는 걸로 알고있는데 이러한 형태는 CSR로 데이터를 보내주는 형태일까요 ??
-
미해결프론트엔드 개발자를 위한, 실전 웹 성능 최적화(feat. React) - Part. 2
궁금한 점이 있어요
캐시 최적화 강의를 보고 난 뒤에 궁금증이 생겼습니다app.use(express.static(path.join(__dirname, "../build"), header));를 통해 빌드된 것들에 대해 해더를 적용하는 것으로 이해했습니다.근데 이렇게 빌드 된 것이 아니라 FE, BE 따로 나뉘어서 배포되어 서로 다른 도메인인 경우 어떻게 해야 하나요?BE는 static 자료가 없이 api만 보내는 기능을 하고 FE는 vercel이나 netlify 또는 다른 EC2로 배포되어 있는 경우를 말씀드립니다.app.use(header);이렇게 하면 될까 했지만 이건 에러를 뱉어냅니다
-
미해결Slack 클론 코딩[실시간 채팅 with React]
CollapseButton이 토글할때마다 어떻게 화살표(?)모양이 css에서 바뀌는지 못찾겟습니다
Direct Message 저 왼쪽의 아이콘(=CollapseButton)이 토글할때마다 바뀌는걸 css코드에서 찾고싶은데 제가 지식이 부족한건지 못찾겠습니다위의 사진을 보면 collapse: boolean으로 가져온거로 collapse일때& i { transform: none; };이게 실행되는건 알겠는데, 이게 실행되면<i className="c-icon ..." (다른 attrs) /> 이 태그가<i className="c-icon ..." (다른 attrs) transform=none; /> 이렇게 변하는데 (이거 맞나요?)transform=none;이면 슬랙쪽에서 만든 p-channel_sidebar__section_heading_expand같은 p-가 달린 속성이 토글되는거 같습니다만,,어떻게 다음의 속성이& i { transform: none; };부모태그인 button의 클래스를 바꾸게 하는건가요??-->css에서 부모태그의 클래스를 바꾸는건 들어본적이 생소해서요 (슬랙에서 제공하는 스타일시트url) 슬랙에서 내부적으로 p-channel_sidebar__section_heading_expand 속성이 있으면 자식i태그에 transform: none이 있으면 부모 클래스속성을 토글하는거 같긴한뎀,,
-
해결됨외워서 끝내는 네트워크 핵심이론 - 기초
Ip헤더질문 강의에서 의문점
질문드립니다~Ip헤더 상위단인 tcp 세그먼트 mss 가 1460byte라고 하셨는데 어떻게 선생님의 ip헤더강의부분에Data가 64k 가 나올수있는거죠? 실제동작은 mtu를위해 잘라야하지만 이론상 64k다 라는건가요?
-
미해결AWS(Amazon Web Service) 입문자를 위한 강의
codedeploy 질문입니다.
안녕하세요. CodeDeploy 실습중에 질문입니다. aws deploy create-application --application-name mywebappaws deploy push --application-name mywebapp --s3-location s3://aws-learner-code-deploy-bucket-zzz/webapp.zip --ignore-hidden-files 위의 명령을 실행해서CodeDeploy에는 mywebapp 애플리케이션이 생성되었는데..aws-learner-code-deploy-bucket-zzz 버킷내부에 webapp.zip 이 생기지 않습니다. 에러도 나지 않았는데, 왜 안되는 것인지..답변 부탁드립니다.
-
미해결HTML+CSS+JS 포트폴리오 실전 퍼블리싱(시즌2)
flex나 grid 로 구현하는것과 비교하면 어떤가요?
CSS 버튼 & 네비게이션 - 3타입 상단 네비게이션 강의float 과 display 등으로 네비의 각 영역을 배치하는데 flex나 grid 로 구현하는것과 비교하면 어떤가요?
-
해결됨실습으로 배우는 AWS 핵심 서비스
강의에서 진행한게 어떤 걸까요?
안녕하세요 강의 잘 듣고 있습니다. 해당 강의 제목은 "[부록] nat인스턴스 설정 해 보기" 라고 되어있는데,진행 내용을 보면 Nat 게이트웨이를 이용 한것 같아 문의 드립니다.Nat 게이트웨이에 대한 내용이 맞을까요?
-
미해결비전공자를 위한 진짜 입문 올인원 개발 부트캠프
fetch 함수가 오류가 납니다
크롬 개발자모드로 했는데 계속 오류가 납니다.. fetch() 가로도 붙여서 했는데 이러면 어떻게 하나요?
-
미해결모든 개발자를 위한 HTTP 웹 기본 지식
last-modified가 겹치면 어떻게 되나요?
"두번째요청-캐시시간초과" 부분에서, 캐시에 있는 데이터를 재사용할 때 데이터의 정보중에 다른건 안보고 last modified만 보나요?? 만약에 content-type이랑 cache-control : max-age도 서로 같고 content-length도 같은 A B가 있을 때 둘다 last modified가 동일하면 A가 캐시에 저장돼있고 서버는 클라로 B를 보내는데도 B를 A로 인식해서 A를 캐시에서 꺼내서 사용할 수도 있나요 ?? 캐시에 저장돼있는 것을 재사용할때 last modified만 체크하는지 궁금합니다.그리고 만약 60초동안 유효한 데이터가 캐시에 있을 때 60초가 지나면 캐시로 사용하지 못한다는 건데, last-modified를 체크한다는 거는 결국 캐시메모리에서 지워지지 않고 재사용할 수 있다는 거잖아요? 그러면 캐시메모리도 무한은 아니니까 안에 들어있는 정보를 지우기도 할텐데 저장돼있는 데이터들은 언제 어떤 기준으로 삭제하는지 궁금합니다 !
-
미해결스프링 MVC 1편 - 백엔드 웹 개발 핵심 기술
was든 웹서버든 다 서버의 역할을 하는거죠 ?
둘다 어쨌든 서버니까 http에서 배웠던 것 처럼 클라이언트랑 정보를 주고받을 수 있고, 만약에 was랑 웹서버를 둘다 쓰게 되는 경우라면(웹서버에 정적, was에 동적 데이터) 웹서버는 서버이자 동시에 was랑 통신하는 클라이언트도 되는 게 맞나요 ??
-
미해결Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
confluent 문제입니다. mysql로 했습니다.
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 해당하는 파일을 넣었습니다.
-
미해결[초급편] 안드로이드 커뮤니티 앱 만들기(Android Kotlin)
kotlin 수업질문입니다. gradle build error
안녕하세요,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
-
미해결설계독학맛비's 실전 FPGA를 이용한 HW 가속기 설계 (LED 제어부터 Fully Connected Layer 가속기 설계까지)
[FPGA 22장] 37:49 즈음 설명해주신 부분에 대한 질문
HW 가속기가 연속으로 동작한다고 할 때,node값은 정해진 상태고,Weight 값이 변경되면서 동작될테니bram0에 데이터 로딩하는 시간을 제외하면SW 연산보다 HW 연산이 더 빨랐음을 확인할 수 있다고 하셨습니다!! 하지만 처음에 FC layer에 대해 설명해주실 때, deep learning의 예시로 이미지를 특정 동물,사물(ex. cat, dog, hat 등)으로 분류하는 기술로 들어주셨었습니다. Q. 그렇다면 이미 완성되어 있는 structure(= weight 고정)에 들어가는 입력(= 이미지 = input node value)만 바뀌게 되는 것이 아닌가요? 강의 너무 잘 듣고 있습니다!! 감사합니다..
-
미해결실전! 스프링 부트와 JPA 활용1 - 웹 애플리케이션 개발
3:00 Model model
Model model 은 @GetMapping 에다가만 적용하나요?여기서 BookForm은 DTO처럼 사용된건데, 꼭 model.attribute("form",new BookForm())처럼 명시해줘야하나요?
-
미해결[C++과 언리얼로 만드는 MMORPG 게임 개발 시리즈] Part3: 자료구조와 알고리즘
Container, Predicate 질문입니다.
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인 객체를 만들었다는 뜻인가요??
-
미해결프로그래밍 시작하기 : 파이썬 입문 (Inflearn Original)
강의 자료 부탁드립니다.
r2songhae@gmail.com 으로 강의자료 부탁드립니다. 감사합니다.
-
미해결실전! 스프링 데이터 JPA
새로운 엔티티가 기본 키 직접 할당 전략을 사용하는 경우 변경 감지로 새로운 엔티티를 추가할 때 merge가 발생하는지?
새로운 엔티티를 구별하는 방법에 대해 강의를 듣다가 기존 영속성 엔티티에 비영속성 엔티티를 추가하고 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' }
-
미해결10분만에 만드는 github blog for Pythonista
블로그 생성
안녕하세요.[22년 추가] PR이 안올라오는 error 관련 강의를 시청하면서 블로그 생성 과정을 따라했습니다.그런데 Action, CI 목록의 Merge pull request #1에서 jekyll build가 실패합니다.어떻게 해결해야 하나요.. 방법을 모르겠습니다.