我有一个服务,它生成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"
}
}
1条答案
按热度按时间cgyqldqp1#
使用文件接收器是不可能的-文件名是静态的,甚至smt也不允许您重新定义它
注意:json转换器将输出json,而不是xml
如果你真的需要这个,你可以试试apache nifi