----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20022/ -----------------------------------------------------------
(Updated April 17, 2014, 12:48 a.m.) Review request for samza. Repository: samza Description (updated) ------- adding a message chooser coordinator to try and extract some of the confusing logic from system consumers into a separate class don't hard code the refresh threshold bump default max msgs per stream partition up to 10k add an unprocessed message counter black list empty system stream partitions Diffs (updated) ----- samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala bbbacb59866c2374853052f7cc11826552f5fb01 samza-core/src/main/scala/org/apache/samza/system/chooser/MessageChooserCoordinator.scala PRE-CREATION Diff: https://reviews.apache.org/r/20022/diff/ Testing ------- Thanks, Chris Riccomini
