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

32 Commits

Author SHA1 Message Date
Rajini Sivaram 9d71489ff0 KAFKA-3548: Use root locale for case transformation of constant strings 
For enums and other constant strings, use locale independent case conversions to enable comparisons to work regardless of the default locale.

Author: Rajini Sivaram <rajinisivaram@googlemail.com>

Reviewers: Manikumar Reddy, Ismael Juma, Guozhang Wang, Gwen Shapira

Closes #1220 from rajinisivaram/KAFKA-3548
 2016-04-20 18:54:30 -07:00
Ismael Juma e3ab96b2f0 MINOR: Example style improvements 
These are minor, but no reason to make our example code look worse than it has to.

Author: Ismael Juma <ismael@juma.me.uk>

Reviewers: Grant Henke

Closes #940 from ijuma/example-style-improvements
 2016-02-22 11:40:33 -08:00
Grant Henke 64b746bd8b KAFKA-3020; Ensure CheckStyle runs on all Java code 
- Adds CheckStyle to core and examples modules
- Fixes any existing CheckStyle issues

Author: Grant Henke <granthenke@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #703 from granthenke/checkstyle-core
 2015-12-21 22:48:03 -08:00
Ashish Singh 5338f8432f KAFKA-2487: change kafka.examples.Consumer to use the new java consumer 
Author: Ashish Singh <asingh@cloudera.com>

Reviewers: Guozhang Wang

Closes #297 from SinghAsDev/KAFKA-2487
 2015-10-15 17:28:23 -07:00
Ismael Juma ed1a548c50 KAFKA-2140 Improve code readability; reviewed by Neha Narkhede 2015-04-26 08:40:58 -07:00
Ashish Singh 5408931a29 kafka-1982; change kafka.examples.Producer to use the new java producer; patched by Ashish Singh; reviewed by Gwen Shapira, Mayuresh Gharat and Jun Rao 2015-04-19 07:46:58 -07:00
Jay Kreps 1c6d5bbac6 KAFKA-1915: Add checkstyle for java code. 2015-02-03 09:16:55 -08:00
Geoffrey Anderson b77099626e kafka-1700; examples directory - README and shell scripts are out of date; patched by Geoffrey Anderson; reviewed by Jun Rao 2014-10-23 16:12:54 -07:00
Joe Stein a8297cc6ca KAFKA-1254 remove vestigial sbt patch by Joe Stein; reviewed by Jun Rao 2014-02-20 00:11:31 -05:00
Ailing Zhang e1f7bea157 kafka-1205; README in examples not update; patched by Ailing Zhang; reviewed by Jun Rao 2014-01-17 08:29:28 -08: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
Swapnil Ghike 2d7403174f kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao 2013-04-25 18:57:31 -07:00
Jun Rao 92f177b309 merge 0.8 to trunk and resolve conflicts 2013-01-25 22:03:39 -08:00
Joe Stein e6aa600813 KAFKA-139 cross-compile multiple Scala versions and upgrade to SBT 0.12.1 patch by Derek Chen-Becker reviewed by Joe Stein 2013-01-21 14:41:47 -05:00
Jun Rao 9249b76d1d merge from 0.8 and resolve conflicts 2013-01-11 18:25:56 -08:00
Jun Rao a40953196e Use uniform convention for naming properties keys; kafka-648; patched by Sriram Subramanian; reviewed by Jun Rao 2013-01-11 16:12:57 -08:00
Jay Kreps 32dae955d5 Merge branch '0.8' into trunk 
Conflicts:
	core/src/main/scala/kafka/log/Log.scala
	core/src/test/scala/unit/kafka/admin/AdminTest.scala
	core/src/test/scala/unit/kafka/log/LogTest.scala
	core/src/test/scala/unit/kafka/server/LogOffsetTest.scala
 2012-12-18 09:43:41 -08: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
Edward Jay Kreps 4be0b1be29 KAFKA-521 Refactor the log subsystem. Patch reviewed by Neha. 
git-svn-id: https://svn.apache.org/repos/asf/kafka/trunk@1416253 13f79535-47bb-0310-9956-ffa450edef68
 2012-12-02 20:50:01 +00:00
Neha Narkhede d7c71c0949 KAFKA-622 Create mbeans per client; patched by Swapnil; reviewed by Neha Narkhede 
git-svn-id: https://svn.apache.org/repos/asf/kafka/branches/0.8@1415021 13f79535-47bb-0310-9956-ffa450edef68
 2012-11-29 01:31:18 +00:00
Edward Jay Kreps 60d0587e8f KAFKA-545 Add some log performance tests. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1410088 13f79535-47bb-0310-9956-ffa450edef68
 2012-11-15 22:54:45 +00:00
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. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1410055 13f79535-47bb-0310-9956-ffa450edef68
 2012-11-15 22:15:14 +00:00
Neha Narkhede 98f6407089 KAFKA-537 Expose clientId in ConsumerConfig and fix correlation id; patched by Yang Ye; reviewed by Neha Narkhede 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1398893 13f79535-47bb-0310-9956-ffa450edef68
 2012-10-16 17:30:46 +00:00
Jun Rao ee855fe1aa remove ZK dependency on producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-369 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1372724 13f79535-47bb-0310-9956-ffa450edef68
 2012-08-14 04:17:27 +00:00
Joe Stein 822963bb9d KAFKA-348 merge trunk to branch 1239902:1310937 patch by Joe Stein reviewed by Jun Rao 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1344526 13f79535-47bb-0310-9956-ffa450edef68
 2012-05-31 01:51:23 +00:00
Jun Rao a5fb217293 new consumer request format; patched by Prashanth Menon; reviewed by Jun Rao and Jay Kreps; KAFKA-240 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1243407 13f79535-47bb-0310-9956-ffa450edef68
 2012-02-13 03:58:37 +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 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
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). 
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1156232 13f79535-47bb-0310-9956-ffa450edef68
 2011-08-10 15:33:21 +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