Kafka JDBC 连接根据记录名称加载不同的表。可能吗?

问题描述 投票:0回答:1

当Kafka使用recordname主题名称策略时,一个主题可以有不同的模式。如果使用正确的设置,对消费者来说没有问题。

但目标是为每个记录名称加载不同的表,例如名称为 SALES_ORDER 的记录转到 SALES_ORDER 表,名称为 SHIPPMENT 的记录转到 SHIPPMENT 表。

据我所知,JDBC 连接器允许根据主题指定表名称,但不能根据架构指定表名称。这个说法正确吗?

apache-kafka jdbc apache-kafka-connect
1个回答
0
投票

这应该是可能的,但您可能需要分叉代码以覆盖使用主题名称的默认逻辑。

命名策略特定于 Confluence 注册表,而 Connect API 是通用的,因此当记录被分解为列和 DDL 时,您将丢失任何此类数据

© www.soinside.com 2019 - 2024. All rights reserved.