我计划写我自己的Kafka连接csv连接器将读取csv文件的数据，并将数据写入一个主题。数据应该以json的形式写入主题。我还遇到了Kafka的汇合插件。我不想用这个来写我自己的。有没有人能告诉我如何为相同的设备创建一个连接器？
yshpjwxd1#
Kafka的官方文档中有一节是关于连接器开发的，所以这可能是最好的第一站。kafka还附带了文件连接器（源和接收器）。看看代码：https://github.com/apache/kafka/tree/trunk/connect/file/src/main/java/org/apache/kafka/connect/file为您的用例修改这些应该不太难。最后，正如您所提到的，已经有一些连接器可以读取csv文件并且是开源的。所以如果你被什么东西卡住了，你可以看看他们是怎么做到的。
1条答案
按热度按时间yshpjwxd1#
Kafka的官方文档中有一节是关于连接器开发的，所以这可能是最好的第一站。
kafka还附带了文件连接器（源和接收器）。看看代码：https://github.com/apache/kafka/tree/trunk/connect/file/src/main/java/org/apache/kafka/connect/file
为您的用例修改这些应该不太难。
最后，正如您所提到的，已经有一些连接器可以读取csv文件并且是开源的。所以如果你被什么东西卡住了，你可以看看他们是怎么做到的。