Debezium可以配置table_name => kafka主題映射嗎？

我讀過http://debezium.io/docs/connectors/mysql/，但我找不到任何有關是否可以配置debezium的信息，以便可以將來自2（或更多）表的更改寫入同一個單獨的kafka主題？在我看來，它總是1表 - > 1主題。Debezium可以配置table_name => kafka主題映射嗎？

來源

2017-10-14 Robert Pankowecki

這似乎是可能的http://debezium.io/docs/configuration/topic-routing/但我不是很確定是否需要在2代表的模式來是完全一樣還是不一樣？ –

是的，使用Single Message Transforms，根據您確定的the link。您可以使用正則表達式（正則表達式）將表映射到所需的主題。 io.debezium.transforms.ByLogicalTableRouter或org.apache.kafka.connect.transforms.RegexRouter都應該這樣做。有後者in this post here的例子：

"transforms":"dropPrefix", 
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter", 
"transforms.dropPrefix.regex":"DC1-TEST-(.*)", 
"transforms.dropPrefix.replacement":"$1"

來源

2017-10-14 19:45:12

'ByLogicalTableRouter'可以讓您充實主鍵，這可以在一個主題中有多個表中的事件時使用。在上面評論的問題中，它的原始用例是針對分片表，但它也適用於具有不同模式的表。 – Gunnar

Debezium可以配置table_name => kafka主題映射嗎？

回答

相關問題