在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集群