tchekai704
/
src-kafka
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
701 Commits
52 Branches
226 Tags
413 MiB
Tree: bf4dbd5ee3
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'bf4dbd5ee3'
${ noResults }
Commit Graph

18 Commits (bf4dbd5ee3be67a214c01aae0bf01b1492994cf5)

Author SHA1 Message Date
Joel Koshy b6479e8adc KAFKA-991; Rename config queue size to queue bytes in hadoop producer; patched by Swapnil Ghike, reviewed by Joel Koshy.
11 years ago
Joel Koshy 8edd3e6302 KAFKA-991; Reduce the queue size in hadoop producer; patched by Swapnil Ghike, reviewed by Jay Kreps and Joel Koshy.
11 years ago
Swapnil Ghike c39d37e9dd kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao
12 years ago
Swapnil Ghike 2d7403174f kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao
12 years ago
David Stein 1976ce8069 KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede
12 years ago
Sam Shah 295734f6ab KAFKA-713 Update Hadoop producer for Kafka 0.8 changes; reviewed by Neha Narkhede
12 years ago
Jun Rao a40953196e Use uniform convention for naming properties keys; kafka-648; patched by Sriram Subramanian; reviewed by Jun Rao
12 years ago
Derek Chen-Becker 45cb03d456 Re-applied old patch from KAFKA-139
12 years ago
Edward Jay Kreps f4ccf21d5d KAFKA-544 Store the key given to the producer in the message. Expose this key in the consumer. Patch reviewed by Jun.
12 years ago
Jun Rao ee855fe1aa remove ZK dependency on producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-369
12 years ago
Neha Narkhede 842da7bfcd KAFKA-350 Enable message replication in the presence of failures; patched by Neha Narkhede; reviewed by Jun Rao and Jay Kreps
12 years ago
Joe Stein a16448b71e KAFKA-368 use the pig core jar from maven instead of distributing it patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
13 years ago
Joe Stein 1af23bb263 KAFKA-368 use the pig core jar from maven instead of distributing it patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
13 years ago
Joe Stein 822963bb9d KAFKA-348 merge trunk to branch 1239902:1310937 patch by Joe Stein reviewed by Jun Rao
13 years ago
Jun Rao c0e190cdef Separate out Kafka mirroring into a stand-alone app; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-249
13 years ago
Neha Narkhede 2552a2488f KAFKA-257 Hadoop producer should use software load balancer; patched by Sam Shah; reviewed by nehanarkhede
13 years ago
Neha Narkhede f53eb16f87 KAFKA 222 Mavenize contrib;patched by nehanarkhede; reviewed jakobhoman and junrao
13 years ago
Neha Narkhede c7fb464938 KAFKA-143 Check and make sure that all source code distributed by the project is covered by one or more approved licenses; patched by nehanarkhede; reviewed by junrao
13 years ago
Henry Saputra 462dfda513 KAFKA-93 | Change and add ASF source header to follow standard ASF source header (http://www.apache.org/legal/src-headers.html).
13 years ago
Edward Jay Kreps 642da2f28c Initial checkin of Kafka to Apache SVN. This corresponds to 709afe4ec7 except that git specific files have been removed and code has been put into trunk/branches/site/etc. This is just a copy of master, branches and history are not being converted since we can't find a good tool for it.
13 years ago