当Kafka使用recordname主题名称策略时,一个主题可以有不同的模式。如果使用正确的设置,对消费者来说没有问题。
但目标是为每个记录名称加载不同的表,例如名称为 SALES_ORDER 的记录转到 SALES_ORDER 表,名称为 SHIPPMENT 的记录转到 SHIPPMENT 表。
据我所知,JDBC 连接器允许根据主题指定表名称,但不能根据架构指定表名称。这个说法正确吗?
这应该是可能的,但您可能需要分叉代码以覆盖使用主题名称的默认逻辑。
命名策略特定于 Confluence 注册表,而 Connect API 是通用的,因此当记录被分解为列和 DDL 时,您将丢失任何此类数据