[2016-10-22 14:50:56,704] WARN [Replica Manager on Broker 2]: While recording the replica LEO, the partition [test,0] hasn't been created. (kafka.server.ReplicaManager)
[2016-10-22 14:50:57,708] WARN [Replica Manager on Broker 2]: While recording the replica LEO, the partition [test,0] hasn't been created. (kafka.server.ReplicaManager)
[2016-10-22 14:50:58,711] WARN [Replica Manager on Broker 2]: While recording the replica LEO, the partition [test,0] hasn't been created. (kafka.server.ReplicaManager)
另一台:
rPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2016-10-22 14:50:56,706] ERROR [ReplicaFetcherThread-0-2], Error for partition [test,0] to broker 2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2016-10-22 14:50:57,709] ERROR [ReplicaFetcherThread-0-2], Error for partition [test,0] to broker 2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2016-10-22 14:50:58,713] ERROR [ReplicaFetcherThread-0-2], Error for partition [test,0] to broker 2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
查看下集群的状态和分区情况是否正常。
是我iptables的问题,谢谢
你的答案