Консольные инструменты Kafka Производитель / Потребительский тест - PullRequest
Новая
       6

Консольные инструменты Kafka Производитель / Потребительский тест

0 голосов
/ 23 мая 2018

После создания «тестовой» темы, 

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 4 --topic test

, которое, как я вижу, было правильно создано: 

kafka-topics --describe --zookeeper localhost:2181 --topic test
Topic:test  PartitionCount:4    ReplicationFactor:1 Configs:
    Topic: test Partition: 0    Leader: 0   Replicas: 0 Isr: 0
    Topic: test Partition: 1    Leader: 0   Replicas: 0 Isr: 0
    Topic: test Partition: 2    Leader: 0   Replicas: 0 Isr: 0
    Topic: test Partition: 3    Leader: 0   Replicas: 0 Isr: 0

У меня есть два консольных окна: Producer и Consumer консоль.Producer подходит: 

kafka-console-producer --broker-list localhost:9092 --topic test
>

Когда я пытаюсь выполнить следующее во втором окне консоли: 

kafka-console-consumer –bootstrap-server localhost:9092 –from-beginning –topic test

Я получаю сообщение об ошибке: 

Exactly one of whitelist/topic is required.
Option                                   Description
------                                   -----------
--blacklist <String: blacklist>          Blacklist of topics to exclude from
                                           consumption.
...Lots more text here...

Как правильно слушать сообщения от Producer в консоли Consumer?

...