我使用jdbc源连接器将数据从oracle摄取到kafka主题。我有Kafka主题创建的小写字母，所以我必须指定 table.whitelist=table_name （在小的情况下）。因为默认情况下它将所有内容都用引号括起来，所以我显式地指定了属性以使其不区分大小写 quote.sql.identifiers=NEVER 但是，它不起作用。
我使用jdbc源连接器将数据从oracle摄取到kafka主题。我有Kafka主题创建的小写字母，所以我必须指定 table.whitelist=table_name （在小的情况下）。因为默认情况下它将所有内容都用引号括起来，所以我显式地指定了属性以使其不区分大小写 quote.sql.identifiers=NEVER 但是，它不起作用。
1条答案
按热度按时间mznpcxlj1#
我假设您使用的是汇合平台。
可以使用转换设置主题名称：
ExtractTopic.ExtractTopic转换可以将任何消息字段设置为主题名。在您的用例中，您可以向jdbc源连接器添加主题名字段
query财产(SELECT ..., 'topicName' from ...)而不是ExtractTopic设置主题名称