Updated Branches: refs/heads/0.8 6b53c649e -> c39d37e9d
kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c39d37e9 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c39d37e9 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c39d37e9 Branch: refs/heads/0.8 Commit: c39d37e9dd97bf2462ffbd1a96c0b2cb05034bae Parents: 6b53c64 Author: Swapnil Ghike <[email protected]> Authored: Mon Jul 8 13:07:16 2013 -0700 Committer: Jun Rao <[email protected]> Committed: Mon Jul 8 13:07:16 2013 -0700 ---------------------------------------------------------------------- .../src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c39d37e9/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java ---------------------------------------------------------------------- diff --git a/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java b/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java index 32f096c..0b435b9 100644 --- a/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java +++ b/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java @@ -49,9 +49,9 @@ public class KafkaOutputFormat<K, V> extends OutputFormat<K, V> Map<String, String> cMap = new HashMap<String, String>(); // default Hadoop producer configs - cMap.put("producer.type", "sync"); - cMap.put("send.buffer.bytes", Integer.toString(64*1024)); - cMap.put("compression.codec", Integer.toString(1)); + cMap.put("producer.type", "sync"); + cMap.put("compression.codec", Integer.toString(1)); + cMap.put("request.required.acks", Integer.toString(1)); kafkaConfigMap = Collections.unmodifiableMap(cMap); }
