我正在尝试将kafka主题数据推送到HDFS。我可以在kafka-consumer-console窗口中看到kafka主题数据。
这是我的代码。不调用writeToWebHDFS(record)方法本身。直到致电HDFS之前……
我建议你不应该重新发明轮子,而应该使用HDFS连接器。您将在此处获得更多详细信息 https://github.com/confluentinc/kafka-connect-hdfs