我使用JDBC源连接器从oracle到kafka主题摄取数据。我有用小写字母创建的kafka主题所以我必须指定table.whitelist=table_name
(小例)。因为默认情况下它会引用所有引号,所以我明确指定了属性,以使它不区分大小写quote.sql.identifiers=NEVER
,但是它不起作用。
我假设你正在使用融合平台。
您可以使用Transformation:ExtractTopic
设置主题名称。 ExtractTopic
转换可以将任何消息字段设置为其主题名称的值。
在您的用例中,您可以将具有主题名称的字段添加到JDBC Source连接器query
属性(SELECT ..., 'topicName' from ...
),而不是使用ExtractTopic
设置主题名称