较早版本不支持Storm UI的kafka抛出“偏移滞后".请将kafka spout更新到最新版本. [英] Storm UI throwing "Offset lags for kafka not supported for older versions. Please update kafka spout to latest version."

问题描述

我已将我的hdp群集升级到2.5，并将Storm-core的拓扑依赖关系升级到1.0.1，将storm-kafka升级到1.0.1.在部署具有新的1.0.1依赖关系的新拓扑之后，一切都在后端正常运行，但是Storm UI的"Acked"，"Emitted"，"Transferred"等始终不显示为零.

I have upgraded my hdp cluster to 2.5 and upgraded topology dependencies of storm-core to 1.0.1 and storm-kafka to 1.0.1. After deploying the new topology with new 1.0.1 dependencies everything is working as expected in the back end but storm UI not showing always zero for "Acked","Emitted", "Transferred" etc.

Storm UI会显示一条消息旧版本不支持kafka的偏移滞后.请将kafka spout更新到最新版本."在拓扑喷口滞后错误"下是什么意思?

Storm UI shows a message "Offset lags for kafka not supported for older versions. Please update kafka spout to latest version." under "Topology spouts lag error" what does it mean ?

推荐答案

我完全同意"Jungtaek Lim"(以上回答).

I completely agree with "Jungtaek Lim" (above answer).

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

Apache Storm in HDP 2.5 is actually not same as official Apache Storm 1.0.1 since it pulled more patches from the next versions (not released yet).

我通过从HDP存储库中拉出HDP 2.5 strom-kafka依赖项(

I fixed this problem by pulling HDP 2.5 strom-kafka dependency from HDP repository (http://repo.hortonworks.com/content/repositories/releases/org/apache/storm/storm-kafka/1.0.1.2.5.0.0-1245/).

这篇关于较早版本不支持Storm UI的kafka抛出“偏移滞后".请将kafka spout更新到最新版本.的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！