[异常处理]class kafka.common.UnknownTopicOrPartitionException (kafka.server.ReplicaFetcherThread)

简介: 在kafka.out日志里出现大量ERROR [ReplicaFetcherThread-0-1], Error for partition [FLAG_DATA_SYC,1] to broker 1:class kafka.

在kafka.out日志里出现大量

ERROR [ReplicaFetcherThread-0-1], Error for partition [FLAG_DATA_SYC,1] to broker 1:class kafka.common.UnknownTopicOrPartitionException (kafka.server.ReplicaFetcherThread)


这是由于删除topic没删干净

在zookeeper里删除下列路径下的数据:
/brokers/topics/[topic]
/consumers/[groupId]/owners/[topic]
/consumers/[groupId]/offsets/[topic]

重启kafka集群




目录
相关文章
|
3月前
|
消息中间件 Java Kafka
Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
29 0
|
5月前
kafka-manager
kafka-manager
26 0
|
9月前
|
消息中间件 缓存 运维
DiDi Kafka-Manager安装和简单使用
DiDi Kafka-Manager安装和简单使用
238 0
|
11月前
|
消息中间件 存储 大数据
Apache Kafka - 安装注意事项
Apache Kafka - 安装注意事项
102 0
Apache Kafka - 安装注意事项
|
11月前
|
消息中间件 监控 Kafka
Apache Kafka-使用Kafak Tool 查看Kafka中的数据
Apache Kafka-使用Kafak Tool 查看Kafka中的数据
336 0
|
11月前
|
消息中间件 Java Kafka
Apache Kafka-CMAK(kafka manager)安装部署使用
Apache Kafka-CMAK(kafka manager)安装部署使用
307 0
|
11月前
|
消息中间件 JSON Java
Apache Kafka-SpringBoot整合Kafka发送复杂对象
Apache Kafka-SpringBoot整合Kafka发送复杂对象
224 0
Apache Kafka-SpringBoot整合Kafka发送复杂对象
|
消息中间件 监控 Kafka
Java--Apache kafka安装和配置
Apache kafka的下载安装和配置。
215 0
Java--Apache kafka安装和配置
|
消息中间件 监控 Java
Apache kafka安装和配置
Apache kafka是一个分布的、分区的、复制的提交日志服务,它使用独一无二的设计,提供了消息系统功能。它提供了类似于JMS的特性,但是在设计实现上完全不同,此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类,发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例组成,每个实例(server)成为broker。无论是kafka集群,还是producer和consumer都依赖于zookeeper来保证系统可用性集群保存一些meta信息。
217 0
Apache kafka安装和配置
|
消息中间件 Kafka Perl
class kafka.common.NotLeaderForPartitionException(kafka.server.ReplicaFetcherThread)异常处理
  [2017-06-15 19:33:14,716] ERROR [ReplicaFetcherThread-0-0], Error for partition [3_7_0_20170615,6] to broker 0:class kafka.
2676 0

热门文章

最新文章