-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19593/
-----------------------------------------------------------
Review request for samza.
Bugs: SAMZA-203
https://issues.apache.org/jira/browse/SAMZA-203
Repository: samza
Description
-------
fix whitespace
drop sleep ms in broker proxy to 100ms not 1000ms. fix thread name in broker
proxy. bump fetch threshold in kafka system consumer to 50000. use
per-partition fetch thresholds now. catch interrupt exceptions in broker proxy
so we don't pollute stderr when we close a broker proxy.
fix kafka config's samza.fetch.threshold punctuation
Diffs
-----
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala
978620a413e231e8d6c57544b3082d286ea20170
samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala
bca2f8660c3e5952f8dbde606b6f9b2760fc526f
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.scala
8ad97dfde939bd85f8b5db18f0790f30360a9274
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala
feecc582e9a52c456aa2bd8830226590986b7ad0
Diff: https://reviews.apache.org/r/19593/diff/
Testing
-------
Thanks,
Chris Riccomini
