kafka 问题 (localhost/127.0.0.1:9092) could not be established. Broker may not be availab
kafka 问题 (localhost/127.0.0.1:9092) could not be established. Broker may not be availab重新配置kafka的配置文件config/server.propertiesadvertised.listeners才是真正的对外代理地址!那么listeners的作用就不是对外提供服务代理,而是监听!# 允许外部端口连接li
·
kafka 问题 (localhost/127.0.0.1:9092) could not be established. Broker may not be availab
重新配置kafka的配置文件config/server.properties
advertised.listeners才是真正的对外代理地址!
那么listeners的作用就不是对外提供服务代理,而是监听!
# 允许外部端口连接
listeners = PLAINTEXT://0.0.0.0:9092
# 外部代理地址
advertised.listeners = PLAINTEXT://192.168.66.151:9092
配置之后,重启kafka,命令行启动消费者,就发现问题已经解决
[root@helpMachine kafka]# ./bin/kafka-server-start.sh -daemon config/server.properties
[root@helpMachine kafka]#
[root@helpMachine kafka]# jps
43403 QuorumPeerMain
48588 Kafka
48607 Jps
[root@helpMachine kafka]# ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic gmall2020_db_c
{"data":null,"database":"gmal2021","es":1616661473000,"id":1,"isDdl":true,"mysqlType":null,"old":null,"pkNames":null,"sql":"DROP TABLE IF EXISTS `base_category_view` /* generated by server */","sqlType":null,"table":"base_category_view","ts":1616663925408,"type":"ERASE"}
{"data":null,"database":"","es":1616661701000,"id":1,"isDdl":false,"mysqlType":null,"old":null,"pkNames":null,"sql":"ALTER USER 'canal'@'%' IDENTIFIED WITH 'mysql_native_password' AS '*E3619321C1A937C46A0D8BD1DAC39F93B27D4458'","sqlType":null,"table":"","ts":1616663925410,"type":"QUERY"}
^CProcessed a total of 2 messages
[root@helpMachine kafka]# vim config/server.properties
更多推荐
所有评论(0)
您需要登录才能发言
查看更多评论