[GitHub] allenma commented on a change in pull request #481: KYLIN-3821 Add consume lag stats

allenma commented on a change in pull request #481: KYLIN-3821 Add consume lag stats URL: https://github.com/apache/kylin/pull/481#discussion_r260692914 ## File path: stream-source-kafka/src/main/java/org/apache/kylin/stream/source/kafka/consumer/KafkaConnector.java ##

[GitHub] allenma commented on a change in pull request #481: KYLIN-3821 Add consume lag stats

allenma commented on a change in pull request #481: KYLIN-3821 Add consume lag stats URL: https://github.com/apache/kylin/pull/481#discussion_r260695771 ## File path: stream-core/src/main/java/org/apache/kylin/stream/core/consumer/IStreamingConnector.java ## @@ -1,46