我讀過http://debezium.io/docs/connectors/mysql/,但我找不到任何有關是否可以配置debezium的信息,以便可以將來自2(或更多)表的更改寫入同一個單獨的kafka主題?在我看來,它總是1表 - > 1主題。Debezium可以配置table_name => kafka主題映射嗎?
0
A
回答
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"
+1
'ByLogicalTableRouter'可以讓您充實主鍵,這可以在一個主題中有多個表中的事件時使用。在上面評論的問題中,它的原始用例是針對分片表,但它也適用於具有不同模式的表。 – Gunnar
相關問題
- 1. 爲kafka主題配置ACL
- 2. 可以將映射映射爲0嗎?
- 3. 圖kafka主機端口映射
- 4. 我可以在Kafka Cluser中擁有數千個主題嗎?
- 5. 無法讀取Kafka主題avro消息
- 6. 自動映射器可以映射分頁列表嗎?
- 7. Kafka kerberos配置問題
- 8. Windows鍵可以映射到Vim嗎?
- 9. AutoMapper可以映射靜態屬性嗎?
- 10. HDF5可以執行「值映射」嗎?
- 11. 可配置的對象映射Java/Spring
- 12. 自定義實體映射是否可以配置父屬性?
- 13. 自動映射器配置
- 14. 複合ID映射配置
- 15. Hazelcast羣集映射配置
- 16. 休眠配置映射
- 17. NHibernate主鍵是1-1映射嗎?
- 18. 主題級別的kafka偏移和日誌保留配置
- 19. 什麼java映射庫可以從Map <String,Object>映射到pojo/bean?
- 20. Kafka:多個獨立消費者羣體可以消費一個主題嗎?
- 21. 主義多對一映射問題
- 22. 與卡夫卡或只嵌入-Debezium的Debezium?
- 23. AutoMapper問題 - 缺少類型映射配置或不支持的映射
- 24. AutoMapper線程問題(缺少類型映射配置或不支持的映射)?
- 25. NHibernate的<any>映射問題
- 26. 映射 - > IHandler <T>
- 27. 是否可以在kafka中鏡像特定主題?
- 28. 是否可以禁用某些kafka主題的緩存?
- 29. 設置table_name的
- 30. 映射註冊時丟失類型映射配置或不支持的映射
這似乎是可能的http://debezium.io/docs/configuration/topic-routing/但我不是很確定是否需要在2代表的模式來是完全一樣還是不一樣? –