// 报错样式:
"Failed to start Sarama producer: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)"
原因:服务器未开启对应端口监听
// 处理,kafka服务器开启端口监听
/sbin/iptables -I INPUT -p tcp --dport 9092 -j ACCEPT
// 报错样式:
"Failed to start Sarama producer: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)"
原因:服务器未开启对应端口监听
// 处理,kafka服务器开启端口监听
/sbin/iptables -I INPUT -p tcp --dport 9092 -j ACCEPT