[异常处理]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
玩转Kafka—Spring&Go整合Kafka
玩转Kafka—Spring&Go整合Kafka
37 0
|
4月前
|
消息中间件 Java Kafka
使用Java编写代码安装Kafka及启动Zookeeper和Kafka
如何使用Java编写代码安装Kafka及启动Zookeeper和Kafka?其中包括安装前准备、修改配置文件、创建日志目录和数据目录等步骤,请提供详细实现过程。
43 0
|
4月前
|
消息中间件 Java Kafka
Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
32 0
|
10月前
|
消息中间件 缓存 运维
DiDi Kafka-Manager安装和简单使用
DiDi Kafka-Manager安装和简单使用
243 0
|
12月前
|
消息中间件 存储 大数据
Apache Kafka - 安装注意事项
Apache Kafka - 安装注意事项
168 0
Apache Kafka - 安装注意事项
|
12月前
|
消息中间件 监控 Kafka
Apache Kafka-使用Kafak Tool 查看Kafka中的数据
Apache Kafka-使用Kafak Tool 查看Kafka中的数据
339 0
|
12月前
|
消息中间件 JSON Java
Apache Kafka-SpringBoot整合Kafka发送复杂对象
Apache Kafka-SpringBoot整合Kafka发送复杂对象
226 0
Apache Kafka-SpringBoot整合Kafka发送复杂对象
|
12月前
|
消息中间件 Java Kafka
Apache Kafka-CMAK(kafka manager)安装部署使用
Apache Kafka-CMAK(kafka manager)安装部署使用
311 0
|
消息中间件 JSON 分布式计算
Structred_Source_Kafka_连接 | 学习笔记
快速学习 Structred_Source_Kafka_连接
80 0
Structred_Source_Kafka_连接 | 学习笔记
|
消息中间件 JSON 分布式计算
Structred_Source_Kafka_需求 | 学习笔记
快速学习 Structred_Source_Kafka_需求
70 0
Structred_Source_Kafka_需求 | 学习笔记