Hi All,

When we test upgrading our existing Samza job from 0.9 to 0.10, we saw our
Kafka Lag metric (KafkaSystemConsumerMetrics "messages-behind-high-watermark
") kept zero.
Since we stopped the old job for a while and then restart the job with 0.10
using the same name, the lag should at least spike at the beginning. In the
application master we did see it's picking up the same checkpoint topic
though.
Any ideas? thanks!

Yuanchi


-- 
Yuanchi Ning

Reply via email to