----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17193/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- make system consumers keep count of messages chosen per system stream. Diffs ----- samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala dd7d35769a99e56898aaa28eb1edf488e27aad15 samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala 9b3160d3c0836779cf53ea918b2188b16ea482a1 samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala 5e3b7cb50c63d165d15d922da9e02de6899a4206 samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala 143be68e63767b9390a673b2619e610be9d25fe9 samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala 36445dfa33c2bb70461cda5b40d5202658b08fb9 Diff: https://reviews.apache.org/r/17193/diff/ Testing ------- Thanks, Chris Riccomini
