我已经将我的hdp集群升级到2.5，并将storm core的拓扑依赖关系升级到1.0.1，将storm kafka的拓扑依赖关系升级到1.0.1。在使用新的1.0.1依赖项部署新拓扑后，后端中的一切都正常工作，但storm ui对于“acked”、“emissued”、“transfered”等并不总是显示为零。
storm ui显示一条消息“offset lags for kafka不支持旧版本。请将Kafka喷口更新到最新版本，“拓扑喷口滞后错误”下是什么意思？
我已经将我的hdp集群升级到2.5，并将storm core的拓扑依赖关系升级到1.0.1，将storm kafka的拓扑依赖关系升级到1.0.1。在使用新的1.0.1依赖项部署新拓扑后，后端中的一切都正常工作，但storm ui对于“acked”、“emissued”、“transfered”等并不总是显示为零。
storm ui显示一条消息“offset lags for kafka不支持旧版本。请将Kafka喷口更新到最新版本，“拓扑喷口滞后错误”下是什么意思？
2条答案
按热度按时间pprl5pva1#
我完全同意“jungtaek lim”（以上答案）。
hdp2.5中的apachestorm实际上与官方的apachestorm1.0.1不同，因为它从下一个版本（尚未发布）中提取了更多的补丁。
我通过从hdp存储库中提取hdp2.5 strom kafka依赖项修复了这个问题(http://repo.hortonworks.com/content/repositories/releases/org/apache/storm/storm-kafka/1.0.1.2.5.0.0-1245/).
z9gpfhce2#
hdp2.5中的apachestorm实际上与官方的apachestorm1.0.1不同，因为它从下一个版本（尚未发布）中提取了更多的补丁。
https://docs.hortonworks.com/hdpdocuments/hdp2/hdp-2.5.0/bk_release-notes/content/patch_storm.html
storm 1.1.0引入了“offset lag for kafka”功能（尚未发布），需要相关的storm kafka版本（因此也从storm 1.1.0开始）。
您需要将storm core和storm kafka的版本设置为relevant（也可能需要将hwx repo设置为pom）。您可以从ui中查看版本，或“./storm version”或“守护程序”日志的结果。