(kafka connect)debezium에서 DB를 읽을 때 해당 데이터에 대한 토픽이름이 조금 길다.
"서버이름.로지컬DB이름.테이블이름" 인데.
이를 다음과 같은 설정을 사용해 '테이블 이름'만 토픽 이름으로 지정할 수 있다.
실제로 이렇게 써야 괜찮다.
| "transforms": "route", "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter", "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)", "transforms.route.replacement": "$3" |
참고
https://debezium.io/docs/connectors/mysql/
https://debezium.io/docs/configuration/topic-routing/
