我试图加载一个文件到Kafka消费者要么与Flume或直接到Kafka。我使用以下链接启动kafka服务器：http://kafka.apache.org/081/quickstart.html正如文件中提到的，我开始了Zookeeper和经纪人。然后我就可以从生产者向消费者发送信息。但是，我想看看我是否可以上传一个输入文件从我的本地机器到Kafka。有什么建议吗？谢谢。
hjzp0vay1#
不能将文件加载到kafka consumer。只能使用kafka producer api在kafka主题中写入数据/文件。因此，您需要将该文件写入一个kafka主题，然后您的用户就可以阅读它了。
1条答案
按热度按时间hjzp0vay1#
不能将文件加载到kafka consumer。只能使用kafka producer api在kafka主题中写入数据/文件。
因此，您需要将该文件写入一个kafka主题，然后您的用户就可以阅读它了。