----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18760/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- SAMZA-168 Add exponential backoff to KafkaSystemAdmin metadata fetch Also refactor ExponentialThreadSleepStrategy to ExponentialSleepStrategy, cleanup and move to samza-core (since it'll be useful for things other than samza-kafka as well) Diffs ----- samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala PRE-CREATION samza-core/src/test/scala/org/apache/samza/util/TestExponentialSleepStrategy.scala PRE-CREATION samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala 0d715827e9db23d9e7350b9df044ccfea718c146 samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala 30e9fc3595a3903cc2c26306c7779585ffd8c064 samza-kafka/src/main/scala/org/apache/samza/util/ExponentialThreadSleepStrategy.scala fde3cf35d29883fd957529620192ab470797b69b samza-kafka/src/test/scala/org/apache/samza/util/TestExponentialThreadSleepStrategy.scala f5e3e4c53e2308798d5808234bacb1be5dc11eea Diff: https://reviews.apache.org/r/18760/diff/ Testing ------- Thanks, Martin Kleppmann
