Guozhang Wang
ae237be1bb
KAFKA-3769: Create new sensors per-thread in KafkaStreams
...
Author: Guozhang Wang <wangguoz@gmail.com>
Reviewers: Damian Guy <damian.guy@gmail.com>, Matthias J. Sax <matthias@confluent.io>, Michael G. Noll <michael@confluent.io>, Greg Fodor <gfodor@gmail.com>, Ismael Juma <ismael@juma.me.uk>, Ewen Cheslack-Postava <ewen@confluent.io>
Closes #1530 from guozhangwang/K3769-per-thread-metrics
8 years ago
Geoff Anderson
801fee89d8
MINOR: cleanup apache license in python files
...
ijuma
As discussed in https://github.com/apache/kafka/pull/1645 , this patch removes an extraneous line from several __init__.py files, and a few others as well
Author: Geoff Anderson <geoff@confluent.io>
Reviewers: Ismael Juma <ismael@juma.me.uk>
Closes #1659 from granders/minor-cleanup-init-files
8 years ago
gaob13
73470b028c
MINOR: Remove the very misleading comment lines
...
It is not true in practice. Maybe the implied feature is not yet implemented or removed.
These lines can be super misleading.
Please merge.
Thank you.
Author: gaob13 <gaob13@mails.tsinghua.edu.cn>
Reviewers: Ismael Juma, Ewen Cheslack-Postava
Closes #793 from gaob13/trunk
9 years ago
Grant Henke
ee1770e00e
KAFKA-2988; Change default configuration of the log cleaner
...
Author: Grant Henke <granthenke@gmail.com>
Reviewers: Ismael Juma <ismael@juma.me.uk>, Jun Rao <junrao@gmail.com>
Closes #686 from granthenke/compaction
9 years ago
Gwen Shapira
53f31432a0
kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao
10 years ago
Manikumar Reddy
49d7f8ee1c
KAFKA-1723; num.partitions documented default is 1 while actual default is 2; patched by Manikumar Reddy; reviewed by Jun Rao
10 years ago
Ewen Cheslack-Postava
9c17747baa
KAFKA-589 Clean shutdown after startup connection failure; reviewed by Neha Narkhede
10 years ago
Anton Karamanov
f489493c38
kafka-1414; Speedup broker startup after hard reset; patched by Anton Karamanov; reviewed by Jay Kreps and Jun Rao
10 years ago
Manikumar Reddy
b428d8cc48
kafka-1531; zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball; patched by Manikumar Reddy; reviewed by Jun Rao
10 years ago
Joe Stein
77118a935e
KAFKA-1289 Misc. nitpicks in log cleaner for new 0.8.1 features patch by Jay Kreps, reviewed by Sriram Subramanian and Jun Rao
11 years ago
Joel Koshy
ac239da502
Update description of num.partitions config in sample server properties - issue reported by Vaibhav Puranik
11 years ago
Neha Narkhede
e602ed0582
KAFKA-1113 log.cleanup.interval.mins property should be renamed; Trivial patch, no review
11 years ago
Roger Hoover
a55ec0620f
kafka-1092; Add server config parameter to separate bind address and ZK hostname; patched by Roger Hoover; reviewed by Jun Rao
11 years ago
Jay Kreps
df18fe13ad
KAFKA-615 fsync asynchronous from log roll. Patch reviewed by Jun and Sriram.
11 years ago
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.
11 years ago
Jun Rao
86e314aa73
kafka-937; fix bug exposed in ConsumerOffsetChecker; patched by Jun Rao; reviewed by Alexey Ozeritskiy
12 years ago
Swapnil Ghike
2d7403174f
kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao
12 years ago
Jay Kreps
e7edb5e1e9
KAFKA-631 Implement a log cleaner for Kafka. Reviewed by Neha.
12 years ago
Jun Rao
53818bb7ee
ConsoleProducer does not exit correctly; kafka-701; patched by Maxime Brugidou; 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
Jay Kreps
c6d41102d8
KAFKA-675 Allow the user to override the host that we bind to. Patch from Matan Amir<matan.amir@voxer.com> with slight changes
...
to improve error messages for a bad host or port.
12 years ago
Joel Jacob Koshy
6c97767b88
Remove custom metrics jar and replace with latest from metrics HEAD; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-585.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1409296 13f79535-47bb-0310-9956-ffa450edef68
12 years ago
Neha Narkhede
1b7b43c6e1
KAFKA-541 Move to metrics csv reporter for system tests; patched by Yang Ye; reviewed by Neha, Jun and Joel
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1401138 13f79535-47bb-0310-9956-ffa450edef68
12 years ago
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
12 years ago
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
12 years ago
Joel Jacob Koshy
542ac86313
Upgrade to metrics jar to 3.x to pick up csv reporter fixes; KAFKA-542; patched by Joel Koshy; reviewed by Neha Narkhede.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1396336 13f79535-47bb-0310-9956-ffa450edef68
12 years ago
Jun Rao
a32d37f6d1
Log errors for unrecognized config options; patched by Jun Rao; reviewed by Jay Kreps; KAFKA-181
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1377220 13f79535-47bb-0310-9956-ffa450edef68
12 years ago
Edward Jay Kreps
1bedde76c2
KAFKA-48 Patch to add "long poll" support to fetch requests.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1332413 13f79535-47bb-0310-9956-ffa450edef68
13 years ago
Edward Jay Kreps
5497e8d156
Leave the default port alone (it was accidentally changed to 9093).
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1198047 13f79535-47bb-0310-9956-ffa450edef68
13 years ago
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
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
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