-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32052/
-----------------------------------------------------------
(Updated March 13, 2015, 9:33 p.m.)
Review request for samza.
Bugs: SAMZA-592
https://issues.apache.org/jira/browse/SAMZA-592
Repository: samza
Description (updated)
-------
updating based on Ewen's feedback
minor nit formatting fix for import
refresh topic metadata if partitions have bad error codes. add a test
add a little test to verify we ignore replica not available exceptions
remove partition metadata check from KafkaSystemAdmin since it's already done
in getOffsets
switch to KafkaUtil.maybeThrowException
Diffs (updated)
-----
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
4a1b31f025ba7b05a7b46041aa8e12074599ce24
samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala
c6e231a2588ce95940aa2da9483a98c6115e38d9
samza-kafka/src/main/scala/org/apache/samza/system/kafka/GetOffset.scala
147aabc947f0cb01c0780edb693e9714f810b5f6
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala
b790be17cfe08da28220ffb381cbd618ebe25cf0
samza-kafka/src/main/scala/org/apache/samza/system/kafka/TopicMetadataCache.scala
4a49d22a3fc403f624ca17a6414d84eaba1898be
samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala
2482f23cc6b9c072651df9cbfe9714ffeb203687
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
3d1e6ecbb3fd95816c722a68c4f5907120eb20d0
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala
e698d2f1f004740a4d74a488c469d8ca8426c6e4
samza-kafka/src/test/scala/org/apache/samza/utils/TestKafkaUtil.scala
PRE-CREATION
samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala
a8b724bf781003142e455fdf1fed2f13d6c18353
Diff: https://reviews.apache.org/r/32052/diff/
Testing
-------
Thanks,
Chris Riccomini
