SAMZA-1283: Expose the buffered-message-size metric
authorXinyu Liu <xiliu@xiliu-ld.linkedin.biz>
Wed, 10 May 2017 23:50:49 +0000 (16:50 -0700)
committerXinyu Liu <xiliu@xiliu-ld.linkedin.biz>
Wed, 10 May 2017 23:50:49 +0000 (16:50 -0700)
commit71930e22fbb48415d8d9a11ef7cc3478dc004bf8
tree46d5f859eba17d5cacb82f194fe6cb9b87850a29
parent36b2f23bb706dfa1cc75fcddf5866cd66e6de623
SAMZA-1283: Expose the buffered-message-size metric

Regardless of whether we enable size limit for the consumer buffer, this metric helps to see what's the buffer size and make configuring size limit easier.

Author: Xinyu Liu <xiliu@xiliu-ld.linkedin.biz>

Reviewers: Jagadish Venkatraman <vjagadish1989@gmail.com>

Closes #184 from xinyuiscool/SAMZA-1283
samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java
samza-api/src/test/java/org/apache/samza/util/TestBlockingEnvelopeMap.java
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.scala