Я пытаюсь использовать сообщения в теме кафки, используя команду ниже. Но это не работает.
bin/kafka-console-consumer.sh --bootstrap-server BROKER_URL --topic TOPIC_NAME --from-beginning
Мой коллега использовал приведенный ниже запрос, и он работает.
bin/kafka-console-consumer.sh --bootstrap-server BROKER_URL --topic TOPIC_NAME --offset 0 --partition 0
Я не уверен насчет разницы между двумя командами и почему вторая работает, но не первая.