ndy2

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

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

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

ConsumerConfig.GROUP_ID_CONFIG 에러

저도 같은 예외를 만났는데 확인해보니&nbsp;<pre><code>
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</code></pre>이런 로그기 찍혀 보니 다른 schema 라 할지라도 현재 연결된 데이터베이스에 같은 이름의 table 이 있으면 테이블을 찾지 못하는 예외가 발생하는 것 같습니다.&nbsp;dwa08 님은 테이블 이름을 변경하는 방식으로 해결하셨는데커넥션을 생성하는 api 요청시 table.whitelist 에 점을 찍어 shema 를 명시해주는 방식으로도 해결할 수 있네요&nbsp;<pre><code>{
 "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"
 }
}</code></pre>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;

Source Connector 오류

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

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

ndy2

Posts