31. Kafka Connect 사용 #3 (source)

1. kafka connect source 등록

2. connector 조회

등록된 source 확인

3. connector 상세조회

상세조회 오류시 

• 파일명 : mysql-connector-java-8.0.27.jar
• 경로 : confluentinc-kafka-connect-jdbc-10.6.0/lib 아래에 배치시킨다

3. connector상세조회(수정)

상세조회

4. Topic 조회

./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

5. source에 사용자 추가

6. Topic 생성 확인

my_topic_users 확인

7. Consumer 확인

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic_users --from-beginning

Database에 Insert한 데이터 확인

두번째 사용자를 insert함과 거의 동시에 컨슈머에 표기됨