kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao
Date Mon, 08 Jul 2013 20:07:34 GMT
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 <sghike@linkedin.com>
Authored: Mon Jul 8 13:07:16 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
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);
   }


Mime
View raw message