root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
16,414 Commits 84 Branches 277 Tags 600 MiB
Commit Graph

3978 Commits

Author SHA1 Message Date
Jay Kreps d2ec321a03 KAFKA-1238 Move metadata req/resp parsing into its own classes and avoid updating cluster metadata if there are no available nodes. 2014-02-09 15:20:33 -08:00
Jay Kreps 962b5475cb KAFKA-1241 Better error message for underflow on read of struct. 2014-02-09 15:20:32 -08:00
Jun Rao 36eae8f63c trivial fix to add missing license header using .gradlew licenseFormatMain and ./gradlew licenseFormatTest; patched by Jun Rao 2014-02-07 14:19:06 -08:00
Jay Kreps fa6339c19c Rename client package from kafka.* to org.apache.kafka.* 2014-02-06 16:25:11 -08:00
Jay Kreps 3220af1fe2 TRIVIAL: Fix misc. numerical issues in histogram. 2014-02-06 10:49:37 -08:00
Jay Kreps 253f86e310 Implement a few of the API suggestions from the mailing list. 2014-02-04 08:39:56 -08:00
Jay Kreps 269d16d3c9 KAFKA-1227 New producer! 2014-01-28 11:15:05 -08:00
Joe Stein e9d07d72fa KAFKA-534 remove client library directory 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1390784 13f79535-47bb-0310-9956-ffa450edef68
 2012-09-27 00:21:45 +00:00
Jun Rao 5e0e0b17fb reverting previous commit for KAFKA-296 because patch didn't apply cleanly 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1300801 13f79535-47bb-0310-9956-ffa450edef68
 2012-03-15 00:39:42 +00:00
Jun Rao 66d8073156 Update Go Client to new version of Go; patched by AaronR; KAFKA-296 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1300777 13f79535-47bb-0310-9956-ffa450edef68
 2012-03-14 22:58:57 +00:00
Joe Stein ccc464c19a Niek Sanders - KAFKA-284 fixed compilation issue for cpp client 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1295388 13f79535-47bb-0310-9956-ffa450edef68
 2012-03-01 02:47:03 +00:00
Neha Narkhede 5c3d5d815c KAFKA-177 Remove the clojure clients until correctly implemented and refactored; patched by nehanarkhede; reviewd by jefferydamick 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1195281 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-30 23:46:41 +00:00
Neha Narkhede 12572102c6 KAFKA-177 Remove the clojure clients until correctly implemented and refactored; patched by nehanarkhede; reviewd by jefferydamick 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1195249 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-30 21:17:13 +00:00
Neha Narkhede 14a1f0dcd6 KAFKA 158 Support for compression in go clients; patched by jeffregydamick; reviewed by nehanarkhede 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1189773 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-27 14:24:27 +00:00
Edward Jay Kreps a0b2aa8847 KAFKA-162 Upgrade the python client to use the new message format. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1186535 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-19 22:14:50 +00:00
Jun Rao c2dc9c0841 Php Client support for compression attribute; patched by AaronR; KAFKA-159 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1185774 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-18 17:57:29 +00:00
Jun Rao e39c11abbc Add compression to C# client; patched by Eric Hauser; KAFKA-153 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1185772 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-18 17:52:13 +00:00
Neha Narkhede 3f0046be1b KAFKA-143 Fixing source code files to have the Apache license header ;patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1183191 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-14 01:32:41 +00:00
Neha Narkhede e27136d81a KAFKA-141 Follow up patch to fix the cpp files; patched by Lorenzo, nehanarkhede; reviewed by junrao, jjkoshy 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1182158 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-12 01:05:28 +00:00
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 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1182023 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-11 19:00:28 +00:00
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 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1180185 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-07 19:51:28 +00:00
Neha Narkhede f34dfc002d Reverting accidental commit 1180110, which is pending review for KAFKA-141 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1180117 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-07 17:33:43 +00:00
Neha Narkhede a99becbe49 Minor patch, removing the .gitigore file 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1180110 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-07 17:18:56 +00:00
Jun Rao 61433bf0a2 ruby kafka gem is not functional; patched by Pierre-Yves Ritschard; KAFKA-135 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1175972 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-26 17:41:02 +00:00
Jun Rao d772600c7b Fix ASF license headers for C# client; patched by Eric Hauser; #KAFKA-137 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1174493 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-23 01:44:40 +00:00
Jun Rao dc66fd9a4b enhancements to .Net; patched by Eric Hauser; KAFKA-85 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1173797 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-21 19:17:19 +00:00
Henry Saputra d0c980dab2 KAFKA-93 | add license to missed files and remove LinkedIn copyright line per ASF guideline. Thanks to Joel Koshy for pointing it out 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1156299 13f79535-47bb-0310-9956-ffa450edef68
 2011-08-10 18:32:09 +00:00
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. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1152970 13f79535-47bb-0310-9956-ffa450edef68
 2011-08-01 23:41:24 +00:00