----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17912/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- use removeTopicPartition instead of nextOffsets.remove in BrokerProxy. Diffs ----- samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala 95a1fb5ab3da8638f73beeed1b130c319dcbc467 Diff: https://reviews.apache.org/r/17912/diff/ Testing ------- Thanks, Chris Riccomini
