Я пытаюсь прочитать файл с помощью производителя kafka. 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
Я погуглил сообщение, и в нем говорится об исправлении команды производителя, которая мне кажется правильной.