----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17193/#review32669 -----------------------------------------------------------
Ship it! Ship It! - Jakob Homan On Jan. 22, 2014, 10:38 a.m., Chris Riccomini wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/17193/ > ----------------------------------------------------------- > > (Updated Jan. 22, 2014, 10:38 a.m.) > > > 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 > >
