kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it相关的知识,希望对你有一定的参考价值。
1.场景1
很相似的问题参考:【Kafka】kafka console received unknown topic or partition error listOffset request
1.1 概述
flink 消费kafka ,然后消费代码没有改变,然后我们的服务升级,kafka版本没变,flink消费的代码没变。但是在有的环境升级不报错 ,有的报错,出现过2次。
报错具体内容如下
Received unknown topic or partition error in fetch for partition {}. The topic/partition may not exist or the user may not have Describe access to it
查看topic的时候如下
kafka-topics.sh --zookeep
以上是关于kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it的主要内容,如果未能解决你的问题,请参考以下文章
kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it
kafkaflink 发送 数据到 kafka 报错 Memory records is not writable
kafkaFLink kafka Unable to retrieve any partitions with KafkaTopicsDescriptor: Fixed Topics