即使在指定quote.sql.identifiers = NEVER之后,table.whitelist也是区分大小写的

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

我使用JDBC源连接器从oracle到kafka主题摄取数据。我有用小写字母创建的kafka主题所以我必须指定table.whitelist=table_name(小例)。因为默认情况下它会引用所有引号,所以我明确指定了属性,以使它不区分大小写quote.sql.identifiers=NEVER,但是它不起作用。

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

我假设你正在使用融合平台。

您可以使用Transformation:ExtractTopic设置主题名称。 ExtractTopic转换可以将任何消息字段设置为其主题名称的值。

在您的用例中,您可以将具有主题名称的字段添加到JDBC Source连接器query属性(SELECT ..., 'topicName' from ...),而不是使用ExtractTopic设置主题名称

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