Commit Graph

247 Commits

Author SHA1 Message Date
Jun Rao 75d95d9b07 merge from 0.8 da4512174b and resolve conflicts 2013-09-11 09:49:48 -07:00
Vladislav Pernin 51de7c55d2 kafka-1031; Little modification to the stop script to be able to kill the proper process; patched by Vladislav Pernin; reviewed by Jun Rao 2013-08-28 09:51:19 -07:00
Jay Kreps 14af713252 Misc. minor house-keeping fixes: add reasonable GC settings, fix up README, fix up example configs, fix the logging for tools, use a log directory for logs instead of the root directory. 2013-08-05 10:10:18 -07:00
Sriram Subramanian 3817857b15 kafka-347; change number of partitions of a topic online; patched by Sriram Subramanian; reviewed by Neha Narkehede, Guozhang Wang, Joel Koshy and Jun Rao 2013-07-22 21:33:28 -07:00
Jun Rao db37ed0054 kafka-965; merge c39d37e9dd from 0.8 to trunk; patched by Jun Rao; reviewed by Jay Kreps 2013-07-10 23:36:51 -07:00
Jun Rao c98bdd3e4f kafka-896; merge 0.8 (988d4d8e65) to trunk; patched by Jun Rao; reviewed by Jay Kreps 2013-07-08 15:42:24 -07:00
Jun Rao 436dd25a48 kafka-259; Give better error message when trying to run shell scripts without having built/downloaded the jars yet; patched by Ashwanth Fernando; reviewed by Jun Rao 2013-05-29 20:26:08 -07:00
Jun Rao 731ba9007d kafka-823; merge 0.8 (51421fcc01) to trunk; patched by Jun Rao; reviewed by Jay Kreps 2013-04-17 21:52:04 -07:00
Cosmin Lehene 158baf661c kafka-843; Re-add the release-zip sbt target; patched by Cosmin Lehene; reviewed by Jun Rao 2013-04-11 11:01:11 -07:00
Neha Narkhede 6dbf9212ae KAFKA-826 Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x; reviewed by Swapnil Ghike, Neha Narkhede, Matt Christiansen, Scott Carey 2013-04-09 16:07:58 -07:00
Jay Kreps c1ed12e44d KAFKA-554 Dynamic per-topic configuration. This patch adds a mechanism for storing per-topic configurations in zookeeper and dynamically making config changes across the cluster. Reviewed by Neha and Jun. 2013-03-08 15:07:39 -08:00
Swapnil Ghike 2457bc49ef KAFKA-513 Add state change log to Kafka brokers; reviewed by Neha Narkhede 2013-03-06 09:35:35 -08:00
Jun Rao b84168a3e3 Fix windows build script - kafka-run-class.bat; patched by Mark deVilliers; reviewed by Jun Rao; kafka-751 2013-02-14 08:23:48 -08:00
Joe Stein cb3359f9f1 KAFKA-731 use a variable for the ivy2 path in kafka-run-class.sh patch by Joe Stein reviewed by Neha Narkhede 2013-01-24 01:23:44 -05:00
Joe Stein aeac593a90 KAFKA-728 snappy jar missing from path in kafka-run-class.sh patch by John Fung reviewed by Joe Stein 2013-01-23 21:02:12 -05:00
John Fung b5d685bb7c KAFKA-722 Fix the classpath in kafka-run-class.sh; reviewed by Neha Narkhede 2013-01-22 12:15:20 -08:00
Joe Stein 5e3e181ace KAFKA-139 cross-compile multiple Scala versions the dependency jars moved and the bin scripts needed to point to the new locations 2013-01-21 21:33:53 -05:00
Derek Chen-Becker 45cb03d456 Re-applied old patch from KAFKA-139
Had to make some additional changes based on further mainline work. Leaving
KafkaProject.scala in place as a reference for now.
2012-12-14 17:12:38 -07:00
Jun Rao e15432efd3 provides windows batch script for starting Kafka/Zookeeper; patched by Antoine Vianey; reviewed by Jun Rao; kafka-581
git-svn-id: https://svn.apache.org/repos/asf/kafka/branches/0.8@1420001 13f79535-47bb-0310-9956-ffa450edef68
2012-12-11 05:38:37 +00:00
Jun Rao 7b2d9c3312 remove ProducerShell; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-638
git-svn-id: https://svn.apache.org/repos/asf/kafka/branches/0.8@1415002 13f79535-47bb-0310-9956-ffa450edef68
2012-11-29 00:03:13 +00:00
Jun Rao 0d9f7ffe4d provides windows batch script for starting Kafka/Zookeeper; patched by Antoine Vianey; reviewed by Jun Rao; kafka-581
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1401782 13f79535-47bb-0310-9956-ffa450edef68
2012-10-24 16:57:56 +00:00
Neha Narkhede 3015d0a447 KAFKA-43 Move leader to preferred replica; patched by Neha Narkhede; reviewed by Joel Koshy and Jun Rao
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1397747 13f79535-47bb-0310-9956-ffa450edef68
2012-10-13 00:39:41 +00:00
Jun Rao 2b13581711 trival fix to remove 2 empty files
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1397623 13f79535-47bb-0310-9956-ffa450edef68
2012-10-12 15:50:10 +00:00
Neha Narkhede 3629f6f882 Changing kafka-server-stop.sh to use SIGTERM for Kafka server process termination. No review
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1397434 13f79535-47bb-0310-9956-ffa450edef68
2012-10-12 04:48:33 +00:00
Neha Narkhede dd44ec672a KAFKA-432 allow consumer to read from followers; patched by Yang Ye; reviewed by Neha and Jun
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1397422 13f79535-47bb-0310-9956-ffa450edef68
2012-10-12 02:56:28 +00:00
Neha Narkhede 93fdcfa0e2 KAFKA-42 part 2: new files
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1396814 13f79535-47bb-0310-9956-ffa450edef68
2012-10-10 21:43:44 +00:00
Neha Narkhede a1698e2b70 Reverting KAFKA-42 since it accidentally contained changes to metrics package. Didn't catch it due to a stale sbt cache. It is better to redo the patch and then commit
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1396726 13f79535-47bb-0310-9956-ffa450edef68
2012-10-10 18:42:57 +00:00
Neha Narkhede 6d0042b4f4 KAFKA-42 Cluster expansion feature; patched by Neha Narkhede; reviewed by Jun Rao
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1396713 13f79535-47bb-0310-9956-ffa450edef68
2012-10-10 18:03:07 +00:00
Edward Jay Kreps 623e2b7e53 KAFKA-424. Fix command line usage description. Patch from Tommie.
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373056 13f79535-47bb-0310-9956-ffa450edef68
2012-08-14 19:59:11 +00:00
Edward Jay Kreps d482531810 KAFKA-425 Wrong class name in scripts. Patch from Akira Kitada reviewed by Jay Kreps.
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373054 13f79535-47bb-0310-9956-ffa450edef68
2012-08-14 19:56:36 +00:00
Neha Narkhede d73355017a KAFKA-301 Implement broker startup procedure; patched by Neha Narkhede; reviewed by Jun Rao and Jay Kreps
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1329509 13f79535-47bb-0310-9956-ffa450edef68
2012-04-23 23:32:59 +00:00
Jun Rao e913a06533 trivial fix to make create topic script executable
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1231403 13f79535-47bb-0310-9956-ffa450edef68
2012-01-13 23:52:21 +00:00
Jun Rao ff668f4fc9 create/delete ZK path for a topic in an admin tool; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-237
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1231400 13f79535-47bb-0310-9956-ffa450edef68
2012-01-13 23:48:27 +00:00
Neha Narkhede 60d88a3ac9 KAFKA-202 Make request processing in kafka asynchronous; patched by jaykreps; reviewed by junrao and nehanarkhede
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1230845 13f79535-47bb-0310-9956-ffa450edef68
2012-01-13 00:03:02 +00:00
Neha Narkhede 336410a777 KAFKA-227 Broker failure system test; patched by johnfung; reviewed by nehanarkhede
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1227916 13f79535-47bb-0310-9956-ffa450edef68
2012-01-06 00:43:46 +00:00
Neha Narkhede f53eb16f87 KAFKA 222 Mavenize contrib;patched by nehanarkhede; reviewed jakobhoman and junrao
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1211616 13f79535-47bb-0310-9956-ffa450edef68
2011-12-07 20:14:15 +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
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 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 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
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
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 d7e0b11d87 fix kafka-server-start.sh to take an optional producer property
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1157560 13f79535-47bb-0310-9956-ffa450edef68
2011-08-14 16:42:35 +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