이펙티브 자바 스터디원 모집 합니다.(Item 15 이후)

이펙티브 자바 스터디 모집 (Item 1 ~ Item 38)

이펙티브 자바 스터디 모집 (Item 1 ~ Item 38)

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" } }