inflearn logo
강의

강의
N
챌린지

챌린지
멘토링

멘토링
N
클립

클립
로드맵

로드맵
지식공유

묻고 답해요

176만명의 커뮤니티!! 함께 토론해봐요.

CollapseButton이 토글할때마다 어떻게 화살표(?)모양이 css에서 바뀌는지 못찾겟습니다

미해결

Slack 클론 코딩[실시간 채팅 with React]

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이 있으면 부모 클래스속성을 토글하는거 같긴한뎀,,

  • typescript
  • Socket.io
  • 웹팩
  • babel
  • react
  • 클론코딩
초간단 댓글 1 좋아요 0 조회수 632

Ip헤더질문 강의에서 의문점

해결됨

외워서 끝내는 네트워크 핵심이론 - 기초

질문드립니다~ Ip헤더 상위단인 tcp 세그먼트 mss 가 1460byte 라고 하셨는데 어떻게 선생님의 ip헤더강의부분에 Data가 64k 가 나올수있는거죠? 실제동작은 mtu를 위해 잘라야하지만 이론상 64k다 라는건가요?

  • network
  • protocol
디노 댓글 1 좋아요 0 조회수 322

codedeploy 질문입니다.

미해결

AWS(Amazon Web Service) 입문자를 위한 강의

안녕하세요. CodeDeploy 실습중에 질문입니다. aws deploy create-application --application-name mywebapp aws 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 이 생기지 않습니다. 에러도 나지 않았는데, 왜 안되는 것인지.. 답변 부탁드립니다.

  • aws
강한 도마뱀 댓글 1 좋아요 0 조회수 281

flex나 grid 로 구현하는것과 비교하면 어떤가요?

미해결

HTML+CSS+JS 포트폴리오 실전 퍼블리싱(시즌2)

CSS 버튼 & 네비게이션 - 3타입 상단 네비게이션 강의 float 과 display 등으로 네비의 각 영역을 배치하는데 flex나 grid 로 구현하는것과 비교하면 어떤가요?

  • jquery
  • javascript
  • HTML/CSS
java-hyun 댓글 1 좋아요 1 조회수 454

강의에서 진행한게 어떤 걸까요?

해결됨

실습으로 배우는 AWS 핵심 서비스

안녕하세요 강의 잘 듣고 있습니다. 해당 강의 제목은 "[부록] nat인스턴스 설정 해 보기" 라고 되어있는데, 진행 내용을 보면 Nat 게이트웨이를 이용 한것 같아 문의 드립니다. Nat 게이트웨이에 대한 내용이 맞을까요?

  • aws
이북자 댓글 1 좋아요 1 조회수 454

fetch 함수가 오류가 납니다

미해결

비전공자를 위한 진짜 입문 올인원 개발 부트캠프

크롬 개발자모드로 했는데 계속 오류가 납니다.. fetch() 가로도 붙여서 했는데 이러면 어떻게 하나요?

  • 머신러닝 배워볼래요?
  • HTML/CSS
  • react
  • javascript
  • react-native
  • tensorflow
  • nodejs
  • express
이경석 댓글 1 좋아요 0 조회수 553

last-modified가 겹치면 어떻게 되나요?

미해결

모든 개발자를 위한 HTTP 웹 기본 지식

"두번째요청-캐시시간초과" 부분에서, 캐시에 있는 데이터를 재사용할 때 데이터의 정보중에 다른건 안보고 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를 체크한다는 거는 결국 캐시메모리에서 지워지지 않고 재사용할 수 있다는 거잖아요? 그러면 캐시메모리도 무한은 아니니까 안에 들어있는 정보를 지우기도 할텐데 저장돼있는 데이터들은 언제 어떤 기준으로 삭제하는지 궁금합니다 !

  • 캐시
  • network
팡휘 댓글 1 좋아요 0 조회수 405

was든 웹서버든 다 서버의 역할을 하는거죠 ?

미해결

스프링 MVC 1편 - 백엔드 웹 개발 핵심 기술

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

  • 서버
  • http
  • MVC
  • spring
팡휘 댓글 1 좋아요 0 조회수 770

confluent 문제입니다. mysql로 했습니다.

미해결

Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)

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 checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest .resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest .resources.RootResource will be ignored. 12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest .resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest .resources.ConnectorsResource will be ignored. 12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest .resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest .resources.ConnectorPluginsResource will be ignored. 12월 03, 2022 5:23:20 오후 org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest .resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest .resources.LoggingResource will be ignored. 12월 03, 2022 5:23:21 오후 org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest .resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest .resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest .resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest .resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest .resources.RootResource contains empty path annotation. [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 failure The 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 failure The 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 more Caused 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 failure The 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 failure The 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 more Caused 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 connect-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\\lib confluentinc-kafka-connect-jdbc-10.6.0\lib 밑에 mysql-connector-java-8.0.29 해당하는 파일을 넣었습니다.

  • architecture
  • spring-cloud
  • spring-boot
  • JPA
  • msa
  • Kafka
JUNI 댓글 1 좋아요 0 조회수 959

kotlin 수업질문입니다. gradle build error

미해결

[초급편] 안드로이드 커뮤니티 앱 만들기(Android Kotlin)

안녕하세요, 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

  • firebase
  • kotlin
  • android
황재연 댓글 5 좋아요 0 조회수 1264

[FPGA 22장] 37:49 즈음 설명해주신 부분에 대한 질문

미해결

설계독학맛비's 실전 FPGA를 이용한 HW 가속기 설계 (LED 제어부터 Fully Connected Layer 가속기 설계까지)

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

  • 임베디드
  • fpga
parkjin0814 댓글 1 좋아요 1 조회수 363

3:00 Model model

미해결

실전! 스프링 부트와 JPA 활용1 - 웹 애플리케이션 개발

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

  • 웹앱
  • spring
  • java
  • JPA
  • spring-boot
omimabi77 댓글 1 좋아요 0 조회수 311

Container, Predicate 질문입니다.

미해결

[C++과 언리얼로 만드는 MMORPG 게임 개발 시리즈] Part3: 자료구조와 알고리즘

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인 객체를 만들었다는 뜻인가요??

  • 기술면접
박정훈 댓글 1 좋아요 0 조회수 445

강의 자료 부탁드립니다.

미해결

프로그래밍 시작하기 : 파이썬 입문 (Inflearn Original)

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

  • python
r2songhae 댓글 1 좋아요 0 조회수 255

새로운 엔티티가 기본 키 직접 할당 전략을 사용하는 경우 변경 감지로 새로운 엔티티를 추가할 때 merge가 발생하는지?

미해결

실전! 스프링 데이터 JPA

새로운 엔티티를 구별하는 방법에 대해 강의를 듣다가 기존 영속성 엔티티에 비영속성 엔티티를 추가하고 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' }

  • spring-boot
  • java
  • JPA
  • spring
chinggin 댓글 1 좋아요 0 조회수 559

블로그 생성

미해결

10분만에 만드는 github blog for Pythonista

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

  • Jekyll
  • blog
중꺾마 댓글 0 좋아요 0 조회수 347

파이어베이스 리얼타임 데이터베이스 저장하기 부분에서

미해결

[왕초보편] 앱 8개를 만들면서 배우는 안드로이드 코틀린(Android Kotlin)

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

  • firebase
  • kotlin
  • android
jankim7878 댓글 1 좋아요 0 조회수 586

endl 과 \n 속도 차이 확인 중 질문

미해결

[C++과 언리얼로 만드는 MMORPG 게임 개발 시리즈] Part1: C++ 프로그래밍 입문

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

  • C++
joke8642 댓글 1 좋아요 0 조회수 391

아이폰 14 프로 프레임 컬럼 수

미해결

피그마(Figma)를 활용한 UI디자인 입문부터 실전까지 A to Z

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

  • figma
  • 웹 디자인
  • 모바일-디자인
zgpgpz72 댓글 1 좋아요 0 조회수 892

window 사용자를 위한 ssh 접속

미해결

Jenkins를 이용한 CI/CD Pipeline 구축

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

  • sonarqube
  • cicd
  • kubernetes
  • jenkins
  • ansible
김상운 댓글 1 좋아요 0 조회수 714

인기 태그

인프런 TOP Writers

주간 인기글