启动消费者
./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic asp_be
报错信息
这个原因是因为kafka 监听配置你可能没有配
打开配置文件
vim server.properties
开启监听设置即可
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092
重启kafka 运行启动消费者命令即可解决