无法通过卡夫卡生产者从文件中读取

Unable to read from file through Kafka producer

我正在尝试使用 kafka producer.Zookeeper 读取文件,而 Broker 服务器是 运行。我能够使用 Kafka 生产者和消费者使用以下命令从命令提示符读取输入 -

Kafka Producer 
kafka-console-producer --topic incoming --broker localhost:9092 

Kafka Consumer 
kafka-console-consumer --topic incoming --zookeeper localhost:2181

为了从文件中读取,我尝试了以下命令行参数 -

kafka-console-producer -–broker-list localhost:9092 -–topic incoming --new-producer < C:\abc.txt

但它产生了以下错误 -

û is not a recognized option

我用谷歌搜索了这条消息,它说要更正我认为正确的生产者命令。

对于 kafka-10,您不需要传递 --new-producer 标志。以下命令对我有用:

kafka-console-producer.sh --broker-list localhost:9092 --topic incoming < C:\abc.txt