我有一个两节点的kafka集群（ec2示例），其中每个节点用作单独的代理。当我使用以下命令在leader示例上运行producer时：

kafka-console-producer.sh   --broker-list localhost:9092 --topic test

我得到以下错误。
测试消息[2017-01-09 13:22:39483]获取相关id为0的元数据时出现警告错误：{test=unknown\u topic\u or\u partition}（org.apache.kafka.clients.networkclient）[2017-01-09 13:22:39，562]获取相关id为1的元数据时出现警告错误：{test=unknown\u topic\u or\u partition}（org.apache.kafka.clients.networkclient）[2017-01-09 13:22:39663]获取相关id为2的元数据时出现警告错误：{test=unknown\u topic\u or\u partition}（org.apache.kafka.clients.networkclient）。。。
列出主题 kafka-topics.sh 显示主题存在。
主题描述包括：

kafka-topics.sh --zookeeper localhost:2181 --describe --topic test

退货

Topic:test PartitionCount:8    ReplicationFactor:1 Configs:
     Topic: test    Partition: 0    Leader: 1   Replicas: 1 Isr: 1
     Topic: test    Partition: 1    Leader: 2   Replicas: 2 Isr: 2
     Topic: test    Partition: 2    Leader: 1   Replicas: 1 Isr: 1
     Topic: test    Partition: 3    Leader: 2   Replicas: 2 Isr: 2
     Topic: test    Partition: 4    Leader: 1   Replicas: 1 Isr: 1
     Topic: test    Partition: 5    Leader: 2   Replicas: 2 Isr: 2
     Topic: test    Partition: 6    Leader: 1   Replicas: 1 Isr: 1
     Topic: test    Partition: 7    Leader: 2   Replicas: 2 Isr: 2

我使用的是Kafka0.10.1.1。 server.properties 文件包含：

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://0.0.0.0:9092
port=9092
host.name=kafka-node1(kafka-node1 for the second host)
advertised.host.name=kafka-node1(kafka-node2 for the second host)
advertised.port=9092

当我尝试从第二台主机生成消息时，我得到以下消息：
warn got error在主题分区test-4上生成相关id为1的响应，正在重试（还剩2次尝试）。错误：不是分区（org.apache.kafka.clients.producer.internals.sender）的\u leader\u。。。。
有人能帮忙吗？