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

FlinkFlink跨集群访问开启Kerberos认证的Kafka

kafka消费相同消费组问题

kafka消费组添加消费者