之前刚安装玩kafka使用它自带的shell脚本 创建了一个topic:test 打开了test的一个生产者和一个消费者,测试是没有问题的,今天再次要调试突然报错了:

创建一个生产者:

 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
 >test1

[2018-03-08 13:59:36,276] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-03-08 14:01:43,637] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-03-08 14:03:51,125] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-03-08 14:05:58,741] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-03-08 14:08:06,741] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-03-08 14:10:14,995] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

这里很郁闷,之前刚装上的时候还没有问题,也是这个命令,找了半天:
我kafka配置文件里 broker = 0
看一下zookeeper 配置信息

>^C[root@test-lufei-6ec9ba1e-3ed1-4409-97dc-4089e858268b kafka_2.11-1.0.0]# bin/zookeeper-shell.sh localhost:2181 <<< "get /brokers/ids/0"
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://172.28.50.143:9092"],"jmx_port":-1,"host":"172.28.50.143","timestamp":"1520487672966","port":9092,"version":4}
cZxid = 0x41
ctime = Thu Mar 08 13:41:12 CST 2018
mZxid = 0x41
mtime = Thu Mar 08 13:41:12 CST 2018
pZxid = 0x41
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x162041f2de00000
dataLength = 196
numChildren = 0

>

这里看到:“endpoints”:[“PLAINTEXT://172.28.50.143:9092”]
创建时生产者的时候我们用的是**localhost,**这里我们改成

bin/kafka-console-consumer.sh --bootstrap-server PLAINTEXT://172.28.50.143:9092 --topic test --from-beginning

向topic中放消息成功!