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

43 Commits (0386790e757fe4eeae4a179e573f71ef8c7de43c)

Author SHA1 Message Date
Alan Lee 8034390ef0 kafka-1406; Fix scaladoc/javadoc warnings; patched by Alan Lee; reviewed by Jun Rao
11 years ago
Joel Koshy 037c054be2 KAFKA-1362; Publish sources and javadoc jars; (also removed Scala 2.8.2-specific actions). Reviewed by Jun Rao and Joe Stein
11 years ago
Joe Stein a8297cc6ca KAFKA-1254 remove vestigial sbt patch by Joe Stein; reviewed by Jun Rao
11 years ago
Moritz Schwörer c9052c5ff5 trivial typo fix; patched by Moritz Schwörer; reviewed by Jun Rao
11 years ago
drunkedcat 99dd94c9b6 kafka-933; Hadoop example running DataGenerator causes kafka.message.Message cannot be cast to [B exception; patched by drunkedcat; reviewed by Jun Rao
11 years ago
Sam Meder bb7b45cd5d kafka-946; Kafka Hadoop Consumer fails when verifying message checksum; patched by Sam Meder; reviewed by Jun Rao
11 years ago
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
Jay Kreps 9ff4e8eb10 KAFKA-739 Handle null message payloads in messages and in the log cleaner. Reviewed by Jun and Neha.
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
Neha Narkhede d7c71c0949 KAFKA-622 Create mbeans per client; patched by Swapnil; reviewed by Neha Narkhede
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
Neha Narkhede 98f6407089 KAFKA-537 Expose clientId in ConsumerConfig and fix correlation id; patched by Yang Ye; reviewed by Neha Narkhede
12 years ago
Edward Jay Kreps 97d434513f KAFKA-506 Hadoop consumer not advancing to next offset. No review.
12 years ago
Joel Jacob Koshy 14b42f7956 getOffset Api should return different latest offset to non-follower and follower consumers. Also, implement a batched version of the getOffset Api. patched by Joel Koshy; reviewed by Jun Rao; KAFKA-501
12 years ago
Joel Jacob Koshy b688c3ba04 KAFKA-391 Refactor fetch/producer requests to use maps instead of several arrays; patched by Joel Koshy; reviewed by Jun Rao.
12 years ago
Jun Rao ba58c9a704 remove errorcode from ByteBufferMessageSet; patched by Swapnil Ghike; reviewed by Jay Kreps and Jun Rao; KAFKA-458
12 years ago
Jun Rao 663d254433 refactor ReplicaManager; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-351
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
Jun Rao f99177766a Add admin RPC requests; clean up Response objects; patched by Yang Ye; reviewed by Jun Rao; KAFKA-349; KAFKA-336
13 years ago
Neha Narkhede 045f4fdca4 KAFKA-46: Message replication feature without failures; patched by Neha Narkhede; reviewed by Jun Rao, Jay Kreps, Prashanth Menon
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
Jun Rao a5fb217293 new consumer request format; patched by Prashanth Menon; reviewed by Jun Rao and Jay Kreps; KAFKA-240
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
Neha Narkhede fa09aacdbd KAFKA-141 Check and make sure that the files that have been donated have been updated to reflect the new ASF copyright;patched by nehanarkhede; reviewd by jjkoshy
13 years ago
Neha Narkhede f34dfc002d Reverting accidental commit 1180110, which is pending review for KAFKA-141
13 years ago
Neha Narkhede a99becbe49 Minor patch, removing the .gitigore file
13 years ago
Jun Rao d42450715c Hadoop Consumer goes into an infinite loop; patched by Sam William; reviewed by Richard Park; KAFKA-131
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