ConsumerConfig.GROUP_ID_CONFIG 에러

@KafkaListener(topics = "example-catalog-topic", groupId = "consumerGroupId")저도 동일한 에러가 발생했는데 어노테이션에 groupId 를 지정해주니 해결되네요

Source Connector 오류

저도 같은 예외를 만났는데 확인해보니 Caused by: org.apache.kafka.connect.errors.ConnectException: The connector uses the unqualified table name as the topic name and has detected duplicate unqualified table names. This could lead to mixed data types in the topic and downstream processing errors. To prevent such processing errors, the JDBC Source connector fails to start when it detects duplicate table name configurations. Update the connector's 'table.whitelist' config to include exactly one table in each of the tables listed below. [["linkocean"."users", "linkoceantest"."users", "mydb"."users"]] at io.confluent.connect.jdbc.source.TableMonitorThread.tables(TableMonitorThread.java:152) ... 14 more이런 로그기 찍혀 보니 다른 schema 라 할지라도 현재 연결된 데이터베이스에 같은 이름의 table 이 있으면 테이블을 찾지 못하는 예외가 발생하는 것 같습니다. dwa08 님은 테이블 이름을 변경하는 방식으로 해결하셨는데커넥션을 생성하는 api 요청시 table.whitelist 에 점을 찍어 shema 를 명시해주는 방식으로도 해결할 수 있네요 { "name" : "my-source-connect", "config" : { "connector.class" : "io.confluent.connect.jdbc.JdbcSourceConnector", "connection.url":"jdbc:mysql://localhost:3306/mydb", "connection.user":"root", "connection.password":"root1234", "mode": "incrementing", "incrementing.column.name" : "id", "table.whitelist":"mydb.users", "topic.prefix" : "my_topic_", "tasks.max" : "1" } }

어플리케이션 로직이 필요한 검증의 분리

답변 감사합니다!

H2 DB tcp연결 불가

해결하진 못했지만 DB를 MySQL로 바꾸어 강의 계속 들을 수 있는 환경을 갖추었습니다. :) MySQL로 쭉쭉 듣겠습니다 감사합니다!