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

Storm UI抛出“kafka的偏移滞后不支持旧版本。请将kafka spout更新到最新版本。“

岳刚洁
2023-03-14

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

共有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喷口更新到最新版本。”“拓扑喷口滞后误差”下是什么意思?

  • [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选项运行以获取

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

  • 几天前,我在play store上发布了Flatter android应用程序,现在我想在play store中更新该应用程序,因此对代码进行了更改,但现在我很困惑,我是否必须使用与第一次发布应用程序时相同的过程来生成新密钥(生成密钥,然后运行Flatter build应用程序包),还是必须遵循其他程序。请帮忙,万分感谢。