потребитель кафки не показывает сообщения?

Question

Я создал новую тему 'rahul' с помощью следующей команды:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic rahul
Created topic "rahul". 

Я также перепроверил темы с помощью

bin/kafka-topics.sh --list --zookeeper localhost:2181

__ consumer_offsets rahhy rahul`

Сейчас запускается производитель:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic rahul
hey

привет, привет

Но когда приходит время потребителю показать сообщения: ничего нет

Answer 1

Начиная с Kafka 0.9, вы не используете Zookeeper для потребления или производства

Попробуйте kafka-console-consumer --topic rahul --bootstrap-server localhost:9092

Существуют и другие способы проверки сообщений, отправленных в Kafka - проверяя, чтосмещения разделов темы изменились с использованием GetOffsetShell