定义 Kafka 文件接收器连接器的唯一名称

Question

我有一个服务，它生成XML字符串并将其发送到Kafka主题，该主题应该生成XML文件。 目前，我正在使用Kafka FileStreamSink连接器，该连接器使用预定义的固定名称生成文件。 该 XML 文件的文件名应根据 XML 内容生成，我该怎么做？

下面是我的文件流接收器连接器配置，具有预定义的文件名。

{
"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"
}

}

Answer 1

使用文件接收器无法执行此操作 - 文件名是静态的，即使是 SMT 也不允许您重新定义它

注意：json 转换器将输出 json，而不是 xml

如果你绝对需要这个，你可以试试Apache Nifi