Невозможно прочитать из файла через производителя Kafka

Я пытаюсь прочитать файл с помощью производителя 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

Я погуглил сообщение, и в нем говорится об исправлении команды производителя, которая мне кажется правильной.


person Narendra Pandey    schedule 17.05.2017    source источник
comment
Какая у тебя версия кафки?   -  person vatsal mevada    schedule 17.05.2017
comment
его кафка_2.11-0.10.0.0   -  person Narendra Pandey    schedule 17.05.2017
comment
Команда, которую я использовал для чтения из файла, верна? Я использовал (grokbase.com/t/kafka/users/157b71babg /kafka-producer-input-file), чтобы настроить его   -  person Narendra Pandey    schedule 17.05.2017


Ответы (1)


Для kafka-10 вам не нужно передавать флаг --new-producer. У меня работает следующая команда:

kafka-console-producer.sh --broker-list localhost:9092 --topic incoming < C:\abc.txt
person vatsal mevada    schedule 17.05.2017
comment
Мне все еще нужно нажать приведенную выше команду, чтобы получить ценность для моего потребителя. Разве это не вызывает это на себя? - person Narendra Pandey; 17.05.2017
comment
Я ожидал, что он будет извлекать данные всякий раз, когда данный файл обновляется. Как мы можем добиться такого поведения? - person Narendra Pandey; 17.05.2017
comment
В этом случае я думаю, что kafka-connect может послужить вашей цели. Хотя я не уверен на 100%. Перейдите по этой ссылке: kafka.apache.org/quickstart#quickstart_kafkaconnect - person vatsal mevada; 17.05.2017