(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/

 

 

 

Posted by '김용환'
,