如何上傳文件給Kafka Consumer？

Question

我正在嘗試使用Flume或直接向Kafka加載文件給Kafka Consumer。我開始使用這個鏈接的卡夫卡服務器：http://kafka.apache.org/081/quickstart.html

正如文檔中提到的，我開始動物園管理員和經紀人。然後，我可以將生產者的消息發送給消費者。但是，我正在嘗試查看是否可以將本地計算機的輸入文件上傳到Kafka。

有什麼建議嗎？謝謝。

Answer 1

您無法將文件加載到卡夫卡消費者中。您只能使用Kafka Producer Api的方式在kafka主題中編寫數據/文件。
因此，您需要將該文件寫入kafka主題，然後您的客戶將能夠讀取它。