| guozh...@apache.org |
kafka git commit: KAFKA-1925; Fix coordinator broker id stuck with INT_MIN; reviewed by Jay Kreps |
Mon, 09 Feb, 17:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-1333; Add the consumer coordinator to server; reviewed by Onur Karaman and Jay Kreps |
Mon, 09 Feb, 23:14 |
| guozh...@apache.org |
kafka git commit: KAFKA-1333 follow-up; Add missing files for the coordinator folder |
Mon, 09 Feb, 23:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-1948; Fix ConsumerTest.testPartitionReassignmentCallback handling issue; reviewed by Gwen Shapira |
Fri, 13 Feb, 01:10 |
| guozh...@apache.org |
kafka git commit: KAFKA-1805; ProducerRecord should implement equals and hashCode; reviewed by Guozhang Wang |
Wed, 18 Feb, 00:19 |
| guozh...@apache.org |
svn commit: r1661588 - /kafka/site/contributing.html |
Mon, 23 Feb, 00:14 |
| jjko...@apache.org |
svn commit: r1656620 - in /kafka/site/082: configuration.html implementation.html |
Tue, 03 Feb, 01:59 |
| jjko...@apache.org |
kafka git commit: KAFKA-1729; Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; reviewed by Jun Rao |
Tue, 03 Feb, 02:17 |
| jjko...@apache.org |
svn commit: r1656966 - /kafka/site/082/implementation.html |
Wed, 04 Feb, 01:17 |
| jjko...@apache.org |
kafka git commit: KAFKA-1697; Remove support for producer ack > 1 on the broker; reviewed by Joel Koshy |
Fri, 13 Feb, 21:08 |
| jjko...@apache.org |
[1/2] kafka git commit: KAFKA-1943; MessageSizeTooLarge and MessageSetSizeTooLarge should not be counted toward broker-side producer failure rate |
Wed, 18 Feb, 01:35 |
| jjko...@apache.org |
[2/2] kafka git commit: KAFKA-1914; Include total produce/fetch stats in broker topic metrics. |
Wed, 18 Feb, 01:35 |
| jjko...@apache.org |
[1/2] kafka git commit: KAFKA-1959; Rename group to groupId in TestOffsetManager due to collision with Thread.group in IBM's JDK; reviewed by Joel Koshy and Gwen Shapira |
Wed, 18 Feb, 07:51 |
| jjko...@apache.org |
[2/2] kafka git commit: KAFKA-1960; .gitignore does not exclude test generated files and folders; reviewed by Joel Koshy and Gwen Shapira |
Wed, 18 Feb, 07:51 |
| jjko...@apache.org |
kafka git commit: KAFKA-1914; follow-up to address unit test failure |
Wed, 18 Feb, 22:38 |
| jjko...@apache.org |
kafka git commit: KAFKA-1914; follow-up to fix SimpleFetchTest; reviewed by Joel Koshy |
Thu, 19 Feb, 00:37 |
| jjko...@apache.org |
kafka git commit: KAFKA-1729; (followup patch)Add constructor to javaapi to allow constructing explicitly versioned offset fetch requests; reviewed by Jun Rao |
Thu, 19 Feb, 02:02 |
| jjko...@apache.org |
kafka git commit: KAFKA-1953; KAFKA-1962; Disambiguate purgatory metrics; restore delayed request metrics; reviewed by Guozhang Wang |
Wed, 25 Feb, 18:59 |
| jkr...@apache.org |
[1/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
[2/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
[3/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
[4/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
[5/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
[6/6] kafka git commit: KAFKA-1915: Add checkstyle for java code. |
Wed, 04 Feb, 04:58 |
| jkr...@apache.org |
svn commit: r1658291 - /kafka/site/082/api.html |
Mon, 09 Feb, 02:00 |
| jkr...@apache.org |
svn commit: r1659333 - /kafka/site/includes/header.html |
Thu, 12 Feb, 17:35 |
| jkr...@apache.org |
svn commit: r1659337 - in /kafka/site/082: design.html ops.html quickstart.html upgrade.html uses.html |
Thu, 12 Feb, 17:48 |
| jkr...@apache.org |
svn commit: r1659338 - /kafka/site/082/design.html |
Thu, 12 Feb, 17:49 |
| jkr...@apache.org |
svn commit: r1659339 - /kafka/site/082/design.html |
Thu, 12 Feb, 17:50 |
| jkr...@apache.org |
svn commit: r1659720 [1/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [4/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [3/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [8/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [5/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [12/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [11/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [14/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [13/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [17/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [16/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [18/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [6/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [2/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [9/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [7/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/org... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [15/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
svn commit: r1659720 [10/18] - in /kafka/site/083: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/consumer/ javadoc/org/apache/kafka/clients/producer/ javadoc/or... |
Fri, 13 Feb, 23:54 |
| jkr...@apache.org |
kafka git commit: KAFKA-1919: Always update the metadata, when a metadata response is received to ensure we back off. |
Sat, 21 Feb, 23:40 |
| jkr...@apache.org |
kafka git commit: KAFKA-1919 Ensure we backoff if metadata response is empty. Double committed on trunk. |
Sat, 21 Feb, 23:58 |
| jkr...@apache.org |
kafka git commit: KAFKA-1757 Unmap file prior to delete on windows. |
Sun, 22 Feb, 05:11 |
| jkr...@apache.org |
[1/2] kafka git commit: KAFKA-1865 Add a flush() method to the producer. |
Sat, 28 Feb, 23:51 |
| jkr...@apache.org |
[2/2] kafka git commit: KAFKA-1865 Add a flush() method to the producer. |
Sat, 28 Feb, 23:51 |
| jun...@apache.org |
svn commit: r1656965 [4/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [9/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [5/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [11/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/k... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [10/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/k... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [1/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [3/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [2/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [7/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [6/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656965 [8/11] - in /kafka/site/082: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javadoc/org/apache/kafka/common/ javadoc/org/apache/ka... |
Wed, 04 Feb, 01:11 |
| jun...@apache.org |
svn commit: r1656967 - in /kafka/site: 082/api.html documentation.html downloads.html |
Wed, 04 Feb, 01:35 |
| jun...@apache.org |
svn commit: r1656968 - /kafka/site/082/api.html |
Wed, 04 Feb, 01:40 |
| jun...@apache.org |
svn commit: r1656969 - /kafka/site/081/documentation.html |
Wed, 04 Feb, 01:43 |
| jun...@apache.org |
svn commit: r1657920 - /kafka/site/082/ops.html |
Fri, 06 Feb, 18:50 |
| jun...@apache.org |
kafka git commit: kafka-1952; High CPU Usage in 0.8.2 release; patched by Jun Rao; reviewed by Guozhang Wang, Ewen Cheslack-Postava and Neha Narkhede |
Wed, 18 Feb, 21:15 |
| jun...@apache.org |
kafka git commit: kafka-1952; High CPU Usage in 0.8.2 release; patched by Jun Rao; reviewed by Guozhang Wang, Ewen Cheslack-Postava and Neha Narkhede |
Wed, 18 Feb, 21:39 |
| jun...@apache.org |
kafka git commit: KAFKA-1729; (followup patch)Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; patched by Joel Koshy; reviewed by Jun Rao |
Thu, 19 Feb, 01:53 |
| jun...@apache.org |
kafka git commit: change build version to 0.8.2.1 |
Thu, 19 Feb, 01:56 |
| jun...@apache.org |
Git Push Summary |
Thu, 19 Feb, 01:57 |
| jun...@apache.org |
kafka git commit: kafka-1971; starting a broker with a conflicting id will delete the previous broker registration; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 23 Feb, 19:51 |
| jun...@apache.org |
kafka git commit: kafka-1971; starting a broker with a conflicting id will delete the previous broker registration; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 23 Feb, 20:13 |
| jun...@apache.org |
kafka git commit: kafka-1984; java producer may miss an available partition; patched by Jun Rao; reviewed by Ewen Cheslack-Postava, Jay Kreps, and Guozhang Wang |
Tue, 24 Feb, 21:52 |
| jun...@apache.org |
kafka git commit: kafka-1984; java producer may miss an available partition; patched by Jun Rao; reviewed by Ewen Cheslack-Postava, Jay Kreps, and Guozhang Wang |
Tue, 24 Feb, 22:07 |
| jun...@apache.org |
Git Push Summary |
Thu, 26 Feb, 22:01 |
| jun...@apache.org |
Git Push Summary |
Thu, 26 Feb, 22:11 |
| jun...@apache.org |
kafka git commit: kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao |
Thu, 26 Feb, 23:03 |
| jun...@apache.org |
kafka git commit: kafka-1400; transient unit test failure in SocketServerTest; patched by Jun Rao; reviewed by Ewen Cheslack-Postava and Jiangjie Qin |
Fri, 27 Feb, 02:02 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1476 Added a ConsumerCommand tool that will replace other consumer related tools in the future; reviewed by Neha Narkhede |
Tue, 10 Feb, 19:59 |
| nehanarkh...@apache.org |
kafka git commit: Minor typo in KafkaConfig; reviewed by Gwen Shapira |
Fri, 20 Feb, 22:44 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1867 liveBroker list not updated on a cluster with no topics; reviewed by Neha Narkhede |
Sat, 21 Feb, 00:22 |
| nehanarkh...@apache.org |
kafka git commit: Leaner DelayedItem; reviewed by Neha Narkhede and Joel Koshy |
Sat, 21 Feb, 00:33 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1947 can't explicitly set replica-assignment when add partitions; reviewed by Neha Narkhede |
Sun, 22 Feb, 04:27 |
| nehanarkh...@apache.org |
kafka git commit: Added script for bin/kafka-consumer-groups.sh that was mistakenly dropped from the original patch for KAFKA-1476 |
Tue, 24 Feb, 16:25 |
| nehanarkh...@apache.org |
kafka git commit: Deleting the ConsumerTest until the issue with the hanging test is resolved; discussed on the mailing list and got several +1s |
Fri, 27 Feb, 22:11 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1664 Kafka does not properly parse multiple ZK nodes with non-root chroot; reviewed by Neha Narkhede and Jun Rao |
Fri, 27 Feb, 23:10 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1866 LogStartOffset gauge throws exceptions after log.delete(); reviewed by Neha Narkhede |
Sat, 28 Feb, 00:10 |
| nehanarkh...@apache.org |
kafka git commit: KAFKA-1824 ConsoleProducer - properties key.separator and parse.key no longer work; reviewed by Neha Narkhede |
Sat, 28 Feb, 15:41 |