我学会了使用kafka connect使用合流spooldir连接器来使用csv文件。是否有任何方法可以将此连接器（或存在任何其他此类连接器）用于“ctrl+a”分隔的文件？我要使用的（源）文件中的记录用换行符分隔，而列用“ctrl+a”分隔。
webghufk1#
我可以通过创建一个 SpoolDirCsvSourceConnector 设置 csv.separator.char=01 （01是ctrl-a的ascii）在文件源属性中。
SpoolDirCsvSourceConnector
csv.separator.char=01
rlcwz9us2#
您可以使用文件脉冲连接器来接收文件。您只需要使用confluent工具安装它并设置相应的配置。您需要配置delimitedrowfilter过滤器以准确解析csv文件。应该有可能知道如何使用“ctrl+a”。一切设置正确后，您可以将csv文件复制到给定的目录中。在配置的时间间隔内，读取文件并将内容复制到主题中。
2条答案
按热度按时间webghufk1#
我可以通过创建一个
SpoolDirCsvSourceConnector设置csv.separator.char=01（01是ctrl-a的ascii）在文件源属性中。rlcwz9us2#
您可以使用文件脉冲连接器来接收文件。您只需要使用confluent工具安装它并设置相应的配置。
您需要配置delimitedrowfilter过滤器以准确解析csv文件。应该有可能知道如何使用“ctrl+a”。
一切设置正确后，您可以将csv文件复制到给定的目录中。在配置的时间间隔内，读取文件并将内容复制到主题中。