Flink1.17.1消费kafka3.5中的数据出现问题Failed to get metadata for topics [flink].

问题呈现

Failed to get metadata for topics [flink]. at org.apache.flink.connector.kafka.source.enumerator.subscriber.KafkaSubscriberUtils.getTopicMetadata(KafkaSubscriberUtils.java:47) at org.apache.flink.connector.kafka.source.enumerator.subscriber.TopicListSubscriber.getSubscribedTopicPartitions(TopicListSubscriber.java:52) at org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.getSubscribedTopicPartitions(KafkaSourceEnumerator.java:219) at org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$notifyReadyAsync$2(ExecutorNotifier.java:80)

解决方法

# server.propertieslisteners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<your_server_ip>:9092# your_server_ip 用于和使用flink进行连接时配置时相同

Flink1.17.1消费kafka3.5中的数据出现问题Failed to get metadata for topics [flink].相关推荐

Flink-1.17.0(Standalone)集群安装-大数据学习系列（四）
前置:集群规划机器信息 Hostname k8s-master k8s-node1 k8s-node2 外网IP 106.15.186.55 139.196.15.28 47.101.63.122 ...
Flink系列之：基于scala语言实现flink实时消费Kafka Topic中的数据
Flink系列之:基于scala语言实现flink实时消费Kafka Topic中的数据一.引入flink相关依赖二.properties保存连接kafka的配置三.构建flink实时消费环境 ...
kafka查看topic中的数据_实战！Kafka Manager能统计出Topic中的记录条数吗？
问题描述今天现场实施同事说Kafka Manager上显示有3500w条记录,但使用我们的平台落地后,一统计发现只有2200w条记录,这是不是说明我们的平台存在丢数据的可能. 经了解,对接方是通过如 ...
阿里巴巴iDST+阿里视频云：计算机视觉和机器学习在消费级视频中的应用
在刚刚圆满落幕的杭州云栖大会上,阿里巴巴董事局主席马云宣布成立达摩院,并将在3年内投资1000亿人民币用于新技术研发.而iDST就是达摩院中的一员,她致力于打造涵盖图像视频.语音交互.自然语言理解.智 ...
使用idea编写SparkStreaming消费kafka中的数据，并对数据进行某一指标的处理【小案例】（五）
接使用idea编写SparkStreaming消费kafka中的数据[小案例](四) https://georgedage.blog.csdn.net/article/details/1035 ...
17.2.3 通过查看triggers数据表中的数据查看触发器的信息
17.2.3 通过查看triggers数据表中的数据查看触发器的信息在MySQL中,会将触发器的信息存储到information_schema数据库中的triggers数据表中.可以通过查看info ...
After Effects Apprentice: 17 Video Walls in Cinema 4D Lite After Effects学徒17：Cinema 4D Lite中的视频墙 Ly
After Effects Apprentice: 17 Video Walls in Cinema 4D Lite 中文字幕 After Effects学徒17:Cinema 4D Lite中的视频 ...
AQAchain：奥趣链在移动端消费、流通领域中的应用
这AQAchain:奥趣链在移动端消费.流通领域中的应用里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片 ...
中美数据中心产业对比及思考
近年来,随着大数据.云计算.人工智能(AI)等前沿技术领域飞速发展,数据应用越来越受到人们重视,从数据背后解读人类社会活动规律和行为习惯,已经为新经济模式形成奠定基础.数据已从以往的计算.统计.测量的 ...
中读取数据_Flink入门实战 (中)
一.Flink 流处理 API 1.Environment getExecutionEnvironment 创建一个执行环境,表示当前执行程序的上下文. 如果程序是独立调用的,则此方法返回本地执行环 ...

Flink1.17.1消费kafka3.5中的数据出现问题Failed to get metadata for topics [flink].

Flink1.17.1消费kafka3.5中的数据出现问题Failed to get metadata for topics [flink].相关推荐

最新文章

热门文章