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

【kafka】Flink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it相关推荐

【Kafka】Flink 消费 kafka 部分分区一直不提交 offset
文章目录 1.概述 1.1 查看消费组 1.2 检测topic 1.3 内置topic 1.4 flink数据监控 1.5 提交offset指标 M.扩展 1.概述一个环境,突然发现,Flink消费 ...
【FLink】Flink 消费 kafka 消费组死掉 Marking the coordinator dead for group 造成数据重复消费
文章目录 1.概述 2.源码分析 2.2 能不能设置多次提交呢? 2.3 监控日志 1.概述首先参考几个案例: [Flink]Flink Kafka 消费卡死消费组卡死 topic无写入实际有数 ...
flink 消费 kafka offset 自动提交
flink 消费kafka 程序重启后,从原先的自动提交的点继续消费,earliest 不用再从开始消费如果开启了checkpoint 以 checkpoint为准 ,enable.auto.com ...
【Flink】flink消费kafka报错 KafkaConsumer.assign Ljava/util/List
文章目录 1.概述 1.概述 flink消费kafka上数据时报错: Caused by: java.lang.NoSuchMethodError: org.apache.kafka.clients. ...
Flink消费kafka，某partition突然从头开始消费，yarn部署，无报错，很奇怪
Flink消费kafka,某partition突然从头开始消费,yarn per job部署,ui页面无报错,检查点也没有异常,很神奇,不知道什么原因?
flink消费kafka时topic partitions 和并行度间的分配源码详解
引言当我们消费kafka的一个topic时,我们知道kafka partition 是和我们设置的并行度是一一对应的: 也就是说,假如我们的topic有12个分区,那我们就设置12个并行度,这样每个 ...
kafka jar包_Windows环境下Flink消费Kafka实现热词统计
前言碎语昨天博主写了<windows环境下flink入门demo实例>实现了官方提供的最简单的单词计数功能,今天升级下,将数据源从socket流换成生产级的消息队列kafka来完成一样的 ...
flink消费kafka从指定时间消费offset的日志
有时生产上会按指定时间消费kafka的数据,具体日志如下: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase [] ...
记录一次Flink消费Kafka空转，无法拉取消息，checkpoint也能成功，但是位置点却不提交的异常处理
起因新起了一个业务,用flink消费实时集市kafka消息,在测试环境跑的好好的,验证也过了,然后上线. 刚上线的当天也好好的,晚上突然在某个点,就拉取不到消息了,上游一直有消息下来,但flink就 ...

【kafka】Flink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it

1.场景1

1.1 概述

【kafka】Flink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it相关推荐

最新文章

热门文章