错误[由于kafka.common.LeaderNotAvailableException而导致的主题test-1的分区元数据]
2017-10-13 12:20
411 查看
应该是partition下面没数据
Kafka使用外部协调框架(默认Zookeeper)来维护配置。看来配置现在与Kafka日志数据不同步。在这种情况下,我会删除受影响的主题数据和相关的Zookeeper数据。
测试环境:
停止
删除这两个服务的数据目录,默认情况下它们是
启动
创建一个新主题
现在您可以再次使用该主题。
生产环境:
由于Kafka主题存储在不同的目录中,您应该删除特定的目录。您还应该
http://stackoverflow.com/questions/23228222/running-into-leadernotavailableexception-when-using-kafka-0-8-1-with-zookeeper-3
Kafka使用外部协调框架(默认Zookeeper)来维护配置。看来配置现在与Kafka日志数据不同步。在这种情况下,我会删除受影响的主题数据和相关的Zookeeper数据。
测试环境:
停止
Kafka-server和
Zookeeper-server
删除这两个服务的数据目录,默认情况下它们是
/tmp/kafka-log和
/tmp/zookeeper。
启动
Kafka-server和
Zookeeper-server再
创建一个新主题
现在您可以再次使用该主题。
生产环境:
由于Kafka主题存储在不同的目录中,您应该删除特定的目录。您还应该
/brokers/{broker_id}/topics/{broken_topic}使用Zookeeper客户端从Zookeeper中删除 。
http://stackoverflow.com/questions/23228222/running-into-leadernotavailableexception-when-using-kafka-0-8-1-with-zookeeper-3
相关文章推荐
- error[No partition metadata for topic test-1 due to kafka.common.LeaderNotAvailableException]
- No partition metadata for topic test due to kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException
- kafka 生产者给消费者发送消息报 class kafka.common.LeaderNotAvailableException