Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/2906 Have tested the changes with Kafka broker running in 2-way SSL and unsecure modes and able to see the lags. The change on the kafka spout side is to return the KafkaConfig properties in getComponentConfiguration so that the lag util can use it.
---