microsoft
/
kafka
зеркало из https://github.com/microsoft/kafka.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность
4 636 коммитов 47 Ветки 21 Тег 109 MiB
Граф коммитов

4636 Коммитов

Автор SHA1 Сообщение Дата
Neha Narkhede d9a8af7782 KAFKA-161 Producer using broker list does not load balance requests across multiple partitions on a broker; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1188333 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-24 19:41:35 +00:00
Edward Jay Kreps 41f14a3e96 KAFKA-166 Add JMX perf tool. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1188288 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-24 18:52:12 +00:00
Edward Jay Kreps 76957e5e3a KAFKA-150 Make the error message for duplicate node ids in zk more self-explanatory. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1188255 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-24 17:47:20 +00:00
Edward Jay Kreps 46b6144a8f KAFKA-164 Fix up configuration with more docs. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1188024 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-24 05:01:40 +00:00
Edward Jay Kreps ce070548e4 KAFKA-165 Add a cli script to use zkCli without having to download ZK. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1187983 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-23 22:03:49 +00:00
Jun Rao 81f8d0dd83 ZK consumer gets into infinite loop if a message is larger than fetch size; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-160 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1186570 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-19 23:52:58 +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 4ad98872ad KAFKA-151 Standard .rat-excludes file and rat script;patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1183190 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-14 01:30:12 +00:00
Neha Narkhede 85989a1baf Deleting the KEYS file from trunk 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1182546 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-12 19:28:46 +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
Jun Rao c0fc483d9f ZK consumer may lose a chunk worth of message during rebalance; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-154 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1182028 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-11 19:11:38 +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
Jun Rao 84c06d4285 Include payload size in DumpLogSegments; patched by Chris Burroughs; reviewed by Jun Rao; KAFKA-152 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1181329 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-11 01:10:37 +00:00
Chris Burroughs a45af2f1ed Restore .gitignore 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1180987 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-10 14:18:40 +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
Neha Narkhede 79092880fd Updating the KEYS file with the correct public keys 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179911 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-07 00:54:13 +00:00
Neha Narkhede e2a91de7a2 Checking in KEYS file to be used to verify Kafka releases 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179887 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 22:28:52 +00:00
Neha Narkhede a1193810b6 KAFKA-149 minor commit to fix the project file to not reference the perf sub project anymore 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179855 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 21:12:35 +00:00
Neha Narkhede 4de899c24d KAFKA-89 consumer should initialize to a valid offset;patched by junrao; reviewed by jjkoshy 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179796 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 19:57:38 +00:00
Neha Narkhede 472723f1cc KAFKA-149: Current perf directory has buggy perf tests; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179791 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 19:48:03 +00:00
Neha Narkhede 101af58f6c KAFKA-141; Added the ASF header to the kafka source and test files where it was missing, deleted the CONTRIBUTORS file to match the convention of other Apache projects; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179788 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 19:45:38 +00:00
Jun Rao 0a9aea7160 add optional mx4j support; patched by Chris Burroughs; reviewed by Jun Rao; KAFKA-78 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179501 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 05:10:09 +00:00
Jun Rao 881eaf14e5 trivial change to print out last offset in DumpLogSegments 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179500 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 05:04:40 +00:00
Neha Narkhede f7b2819bff reverting r1178669 to fix KAFKA-147 kafka integration tests fail on a fresh checkout; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179487 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-06 01:57:38 +00:00
Neha Narkhede 4f28442864 KAFKA-145 Kafka server mirror shutdown bug; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179466 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-05 22:48:10 +00:00
Neha Narkhede bac6d9c3fa KAFKA-146 testUnreachableServer sporadically fails; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1179043 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-05 02:49:56 +00:00
Neha Narkhede dd62e77f90 KAFKA-129 ZK-based producer can throw an unexpceted exception when sending a message; patched by nehanarkhede; reviewed by junrao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178997 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-04 22:43:00 +00:00
Chris Burroughs 513c4a59d8 Adding a .0 for easier post-release support. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178988 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-04 22:30:28 +00:00
Chris Burroughs a7b4731947 obsessive compulsive tag team: Replace tabs with spaces 
patch by jkreps; reviewed by cburroughs for KAFKA-114

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178670 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-04 01:41:25 +00:00
Chris Burroughs 4c2d121b26 Update to sbt 0.7.7 
patch by cburroughs; reviewed by junrao for KAFKA-92

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178669 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-04 01:41:02 +00:00
Edward Jay Kreps 59a5c3215a KAFKA-130 Add a "console producer" that sends messages from standard input 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178659 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-04 00:54:14 +00:00
Edward Jay Kreps 031a559e89 KAFKA-125 On Linux, the test can throw SocketException instead of EOFException, that is cool too. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178553 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-03 20:11:36 +00:00
Jun Rao 42c2241cfb kafka-server-start.sh ignores JMX_PORT; patched by Mathias Herberts; reviewed by Jun Rao; KAFKA-144 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178434 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-03 15:49:36 +00:00
Jun Rao 596c8d1af7 JMX bean that reports #message/sec in consumer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-136 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1178298 13f79535-47bb-0310-9956-ffa450edef68
 2011-10-03 04:57:06 +00:00
Jun Rao efc7a8a0cd Expose total metrics through MBeansp; patched by Pierre-Yves Ritschard; reviewed by Jun Rao; KAFKA-140 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1177798 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-30 19:36:07 +00:00
Jun Rao da35513245 trival fix to make hash code positive; patched by Joel Koshy; reviewed by Jun Rao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1177516 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-30 05:44:13 +00:00
Jun Rao 1b0feb6345 Bug in the queue timeout logic of the async producer; patched by Neha Narkhede; reviewed by Jun Rao; KAFKA-138 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1176672 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-28 00:51:51 +00:00
Jun Rao 4092ceeb5a Consumer needs a pluggable decoder; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-3 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1176671 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-28 00:42:30 +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 5fbac30f86 Log flush should complete upon broker shutdown; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-126 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1175966 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-26 17:34:48 +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
Edward Jay Kreps 8efb536aff KAFKA-132 Patch from Scott Andreas to avoid flush when there is nothing to flush. Looks like due to atime attribute in the filesystem this can lead to flushing file metadata. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1171889 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-17 03:31:15 +00:00
Edward Jay Kreps 54f49314af KAFKA-70 Patch from Prashanth Menon to add space-based retention setting. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1171886 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-17 03:21:06 +00:00
Jun Rao 6af334d69a Tool to watch consumer offsets and lag; patched by Joel Joshy; reviewed by Jun Rao; KAFKA-127 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1167405 13f79535-47bb-0310-9956-ffa450edef68
 2011-09-09 23:49:45 +00:00