http://debezium.io/docs/connectors/mysql/을 읽었 지만 debezium을 구성하여 2 개 (또는 그 이상) 테이블의 변경 사항을 동일한 단일 kafka에 기록 할 수 있는지 여부에 대한 정보를 찾을 수 없습니다. 이야기? 항상 1 개의 테이블-> 1 개의 주제 인 것 같습니다.
예, 식별 한 링크 별로 단일 메시지 변환을 사용 합니다. 정규식 (정규식)을 사용하여 테이블을 필요한 주제에 매핑 할 수 있습니다. 둘 다 또는 트릭을 수행해야합니다. 이 게시물 에는 후자의 예가 있습니다 .io.debezium.transforms.ByLogicalTableRouter
org.apache.kafka.connect.transforms.RegexRouter
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다