Как я могу попытаться прочитать topi c в kafka, когда я получаю сообщение об ошибке «Отсутствует обязательный аргумент» [topic]

Question

Я получаю сообщение об ошибке при чтении topi c из кластера с одним узлом

kafka-console-producer.bat -- broker-list localhost:9092 -- topic raja

Ошибка ниже

Missing required argument "[topic]"

kafka version-kafka_2.13-2.4.0

Answer 1

Я предлагаю вам больше исследовать и обучать.

Вы используете kafka CONSUMER для чтения из топи c, НЕ ПРОИЗВОДИТЕЛЯ,
, а также, как упоминал @Robin Moffatt, когда я печатал ответ,
убрать пробелы между метками параметров:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic raja

Это должно работать.

Если вы хотите прочитать topi c с самого начала, добавьте также:

--from-beginning

Answer 2

Между метками параметров есть пробел, поэтому он не будет работать. Также обратите внимание, consumer не producer, если вы читаете из топи c.

Попробуйте:

kafka-console-consumer.bat --broker-list localhost:9092 --topic raja

Ссылка: https://kafka.apache.org/documentation/#quickstart_consume