UVN
1667c16be1
MINOR: Read configuration fields from ProducerConfig in example ( #4601 )
...
Reading the configuration field names from ProducerConfig class and taking the key and value serializer names from class name directly instead of hardcoding.
7 years ago
Vahid Hashemian
f85c18032b
KAFKA-3264; Deprecate the old Scala consumer (KIP-109)
...
Author: Vahid Hashemian <vahidhashemian@us.ibm.com>
Reviewers: Ismael Juma <ismael@juma.me.uk>
This patch had conflicts when merged, resolved by
Committer: Ismael Juma <ismael@juma.me.uk>
Closes #2328 from vahidhashemian/KAFKA-3264
8 years ago
Matthias J. Sax
d0e436c471
MINOR: improve license header check by providing head file instead of (prefix) header regex
...
Author: Matthias J. Sax <matthias@confluent.io>
Reviewers: Jason Gustafson <jason@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>
Closes #2303 from mjsax/licenseHeader
8 years ago
Qian Zheng
39a1c42dfc
MINOR: add a space to separate two words
...
I think we should add a space here, otherwise the two words will join together.
And replace the host string with a constant, otherwise when I need to modify the host, I need to modify several files.
Author: 郑谦00117553 <00117553@zte.intra>
Reviewers: Guozhang Wang <wangguoz@gmail.com>
Closes #2132 from ZhengQian1/trunk
8 years ago
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
9 years ago
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
9 years ago
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
9 years ago
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
9 years ago
Ismael Juma
ed1a548c50
KAFKA-2140 Improve code readability; reviewed by Neha Narkhede
10 years ago
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
10 years ago
Jay Kreps
1c6d5bbac6
KAFKA-1915: Add checkstyle for java code.
10 years ago
Geoffrey Anderson
b77099626e
kafka-1700; examples directory - README and shell scripts are out of date; patched by Geoffrey Anderson; reviewed by Jun Rao
10 years ago
Joe Stein
a8297cc6ca
KAFKA-1254 remove vestigial sbt patch by Joe Stein; reviewed by Jun Rao
11 years ago
Ailing Zhang
e1f7bea157
kafka-1205; README in examples not update; patched by Ailing Zhang; reviewed by Jun Rao
11 years ago
Swapnil Ghike
2d7403174f
kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao
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
...
Had to make some additional changes based on further mainline work. Leaving
KafkaProject.scala in place as a reference for now.
12 years ago
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
12 years ago
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
12 years ago
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
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.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1410055 13f79535-47bb-0310-9956-ffa450edef68
12 years ago
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
12 years ago
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
12 years ago
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
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
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1310645 13f79535-47bb-0310-9956-ffa450edef68
13 years ago
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
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
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1180185 13f79535-47bb-0310-9956-ffa450edef68
13 years ago
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
13 years ago
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
13 years ago
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
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 ).
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1156232 13f79535-47bb-0310-9956-ffa450edef68
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.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1152970 13f79535-47bb-0310-9956-ffa450edef68
13 years ago