为kafka文件接收器连接器定义唯一名称

jm81lzqq  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(538)

我有一个服务,它生成xml字符串并将其发送到kafka主题,而kafka主题应该生成xml文件。目前,我正在使用kafka filestreamsink连接器,它生成具有预定义固定名称的文件。该xml文件的文件名应该根据xml内容生成,我该怎么做?
下面是我使用预定义文件名的filestreamsink连接器配置。

{
    "name": "file_sink_stream_01",
    "config": {

            "connector.class": "FileStreamSink",
            "group.id": "file_sink_stream_connector",

            "tasks.max": "1",

            "key.converter": "org.apache.kafka.connect.json.JsonConverter",
            "key.converter.schemas.enable":"false",

            "value.converter": "org.apache.kafka.connect.json.JsonConverter",
            "value.converter.schemas.enable": "false",

            "topics": "stream_userid_stream",
            "file": "file.xml"

    }

}

cgyqldqp

cgyqldqp1#

使用文件接收器是不可能的-文件名是静态的,甚至smt也不允许您重新定义它
注意:json转换器将输出json,而不是xml
如果你真的需要这个,你可以试试apache nifi

相关问题