当前位置: 首页 > 知识库问答 >
问题:

Storm UI抛出“Kafka的偏移滞后对旧版本不支持。请将Kafka喷口更新到最新版本。”

沙柏
2023-03-14

Storm UI显示一条消息“较旧版本不支持Kafka的偏移滞后。请将Kafka喷口更新到最新版本。”“拓扑喷口滞后误差”下是什么意思?

共有1个答案

公西财
2023-03-14

HDP2.5中的Apache Storm实际上与官方的Apache Storm 1.0.1不同,因为它从下一个版本(尚未发布)中提取了更多补丁。

https://docs.hortonworks.com/hdpdocuments/hdp2/hdp-2.5.0/bk_release-notes/content/patch_storm.html

特性“Kafka的偏移滞后”是Storm 1.1.0(尚未发布)引入的,并需要相关的Storm-Kafka版本(因此从Storm 1.1.0开始)。

 类似资料:
  • Storm UI显示一条消息:“旧版本不支持kafka的偏移滞后。请将kafka spout更新到最新版本。”在“拓扑喷出滞后误差”下是什么意思?

  • [root@PPWFMD509bin]#./线程“main”java.lang.UnsupportedClassVersionError:org/apache/cassandra/cli/CliMain:Unsupported major中的cassandra cli异常。在java.lang.ClassLoader的51.0次要版本。java.lang.ClassLoader.defineCla

  • 问题内容: 我在安装项目时遇到了一些问题。 我拥有运行 Swift 3* 的最新版本的 Xcode ,并且当我尝试安装alamofire时遇到800个编译器错误。 * 显然地 构建Alamofire 4.0.0+需要CocoaPods 1.1.0+ 我看着终端机上的CocoaPods版本,它说我的版本是1.0.1。 我猜运行更新没有用,因为CocoaPods 1.1是beta版。 因此,我不确定如

  • 伙计们,请帮帮我,我不能在Flitter中构建或升级任何东西,我会遇到很多类似失败的错误:构建失败,但有一个例外。 出了什么问题:任务'执行失败:app: check ReleaseAarMetadata'。 发生多个任务操作失败:执行com时发生故障。Android建筑格雷德尔。内部的任务。CheckAarMetadataWorkAction > 尝试:使用--stacktrace选项运行以获取

  • 我计划从JBOSS EAP迁移到支持旧版本Java如6或7的Wildfly版本。 我找不到与野生苍蝇和java的兼容性矩阵。 另外,有任何版本的野蝇支持solaris 5吗? wildfly 8是否支持旧的java和Solaris版本。 有人能给我指一下矩阵吗?在那里我可以找到wildfly的兼容性和需求。

  • 帐号说明 旧版帐号:开放平台开发者帐号 新版帐号:生态云帐号,orgId为 CL+uuid 新版SDS与旧版SDS功能相同,仅认证授权体系不同。新版SDS已经与生态云的用户管理模块集成,认证授权更加简洁、易于管理。推荐使用新版SDS! 迁移接口 web页面: 生态云旧版帐号界面有表迁移按钮入口,进入迁移界面后,选择要迁移到的新版orgId和需要迁移的表即可 SDK: 对于无法登录web页面的情况,