"Ctrl+A" 个分隔文件的 kafka 连接器

kafka connector for "Ctrl+A" delimited files

我学会了使用 Kafka connect 通过 Confluent SpoolDir 连接器使用 CSV 文件。有什么方法可以将此连接器(或是否存在任何其他此类连接器)用于“Ctrl+A”分隔文件?

我要使用的(源)文件中的记录由换行符分隔,而列由“Ctrl+A”分隔。

您可以使用 file pulse connector 获取文件。你只需要使用 confluent 工具安装它并设置相应的配置。

您需要配置 DelimitedRowFilter Filter 才能准确解析 CSV 文件。应该有一些如何使用“Ctrl+A”的方法。

当一切正确时 set-up 您可以将 CSV 文件复制到给定目录中。在配置的时间间隔内读取文件并将内容复制到主题中。

我能够使用 SpoolDir 连接器通过创建 SpoolDirCsvSourceConnector 并在 file-source 属性中设置 csv.separator.char=01(01 是 Ctrl-A 的 ASCII)来做到这一点.