root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao

This commit is contained in:
Swapnil Ghike 2013-07-08 13:07:16 -07:00 committed by Jun Rao
parent 6b53c649e9
commit c39d37e9dd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java
View File

@ -49,9 +49,9 @@ public class KafkaOutputFormat<K, V> extends OutputFormat<K, V>
Map<String, String> cMap = new HashMap<String, String>(); Map<String, String> cMap = new HashMap<String, String>();
// default Hadoop producer configs // default Hadoop producer configs
cMap.put("producer.type", "sync"); cMap.put("producer.type", "sync");
cMap.put("send.buffer.bytes", Integer.toString(64*1024)); cMap.put("compression.codec", Integer.toString(1));
cMap.put("compression.codec", Integer.toString(1)); cMap.put("request.required.acks", Integer.toString(1));
kafkaConfigMap = Collections.unmodifiableMap(cMap); kafkaConfigMap = Collections.unmodifiableMap(cMap);
} }