message-queue - 如何使用一个 Kafka 代理从 NoReplicaOnlineException 中恢复？

Question

我们有一个非常简单的 Kafka 0.8.1.1 在我们的开发实验室中设置。它只是一个节点。我们会定期遇到此错误:

[2015-08-10 13:45:52,405] ERROR Controller 0 epoch 488 initiated state change for partition [test-data,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [test-data,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
        at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
        at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
        at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
        at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
        at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
        at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)

任何人都可以推荐一种从中恢复的策略吗？是否有这样的事情，或者我们是否需要构建另一个或两个节点并在我们的主题上设置复制因子以覆盖我们放入集群的所有节点？

我们有 3 个 zookeeper 节点，它们对 Storm 和 HBase 等其他应用程序的响应非常好，所以我们非常有信心 ZooKeeper 不会在这里受到指责。有任何想法吗？

Answer 1

这个问题是关于 Kafka 0.8 的，如果我没记错的话应该不支持了。但是，对于 future 的读者，以下指南应该是相关的:

如果您关心稳定性、正常运行时间、可靠性或这个大方向的任何事情，请确保您至少拥有 3 个 kafka 节点。

如果您在旧的 kafka 版本中遇到问题，请认真考虑升级到最新的 kafka 版本。在撰写本文时，我们已经在 Kafka 2