[异常处理]class kafka.common.UnknownTopicOrPartitionException (kafka.server.ReplicaFetcherThread)
Posted liguangsunls
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了[异常处理]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.common.UnknownTopicOrPartitionException (kafka.server.ReplicaFetcherThread)
这是因为删除topic没删干净
在zookeeper里删除下列路径下的数据:
/brokers/topics/[topic]
/consumers/[groupId]/owners/[topic]
/consumers/[groupId]/offsets/[topic]
重新启动kafka集群
以上是关于[异常处理]class kafka.common.UnknownTopicOrPartitionException (kafka.server.ReplicaFetcherThread)的主要内容,如果未能解决你的问题,请参考以下文章
Kafka Server写数据的时候报错org.apache.kafka.common.errors.RecordTooLargeException
kafka启动报错:kafka.common.KafkaException: Failed to acquire lock on file .lock
JBOSS 给出 org.apache.kafka.common.KafkaException: auth.conf cannot be read
kafka.common.errors.TimeoutException:Timeout expired while fetching topic metadata
在Spring boot kafka中的ProducerConfigs中将ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG设置为IntegerSerializer时