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/ ja

2015-02-03 Thread junrao
Added: kafka/site/082/javadoc/index.html URL: http://svn.apache.org/viewvc/kafka/site/082/javadoc/index.html?rev=1656965view=auto == --- kafka/site/082/javadoc/index.html (added) +++ kafka/site/082/javadoc/index.html Wed

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/ ja

2015-02-03 Thread junrao
Added: kafka/site/082/javadoc/org/apache/kafka/common/errors/TimeoutException.html URL: http://svn.apache.org/viewvc/kafka/site/082/javadoc/org/apache/kafka/common/errors/TimeoutException.html?rev=1656965view=auto == ---

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/ ja

2015-02-03 Thread junrao
Author: junrao Date: Wed Feb 4 01:11:43 2015 New Revision: 1656965 URL: http://svn.apache.org/r1656965 Log: update api for 082 Added: kafka/site/082/javadoc/ kafka/site/082/javadoc/allclasses-frame.html kafka/site/082/javadoc/allclasses-noframe.html kafka/site/082/javadoc

svn commit: r1656967 - in /kafka/site: 082/api.html documentation.html downloads.html

2015-02-03 Thread junrao
Author: junrao Date: Wed Feb 4 01:35:26 2015 New Revision: 1656967 URL: http://svn.apache.org/r1656967 Log: flip the main doc to 082 Modified: kafka/site/082/api.html kafka/site/documentation.html kafka/site/downloads.html Modified: kafka/site/082/api.html URL: http

svn commit: r1656968 - /kafka/site/082/api.html

2015-02-03 Thread junrao
Author: junrao Date: Wed Feb 4 01:40:13 2015 New Revision: 1656968 URL: http://svn.apache.org/r1656968 Log: fix javadoc link from api page Modified: kafka/site/082/api.html Modified: kafka/site/082/api.html URL: http://svn.apache.org/viewvc/kafka/site/082/api.html?rev=1656968r1=1656967r2

kafka git commit: KAFKA-1723 (delta patch to fix javadoc); make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao

2015-01-14 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk bfb2da3c8 - a61117840 KAFKA-1723 (delta patch to fix javadoc); make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1723; (followup patch to fix javadoc for java 8) make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 17c8bdcbb - 988e695fa KAFKA-1723; (followup patch to fix javadoc for java 8) make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

kafka git commit: kafka-1870; Cannot commit with simpleConsumer on Zookeeper only with Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 988e695fa - 1d3fd0f6c kafka-1870; Cannot commit with simpleConsumer on Zookeeper only with Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1870; Cannot commit with simpleConsumer on Zookeeper only with Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 602d572f6 - 1769642bb kafka-1870; Cannot commit with simpleConsumer on Zookeeper only with Java API; patched by Jun Rao; reviewed by Jeol Koshy and Sriharsha Chintalapani Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1864; Revisit defaults for the internal offsets topic; patched by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 1d3fd0f6c - 7a313999d kafka-1864; Revisit defaults for the internal offsets topic; patched by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1864; Revisit defaults for the internal offsets topic; patched by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 1769642bb - 5174df537 kafka-1864; Revisit defaults for the internal offsets topic; patched by Jun Rao; reviewed by Jeol Koshy, Neha Narkhede, and Gwen Shapira Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: trivial change to remove -UseCompressedOops option from script

2015-01-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 5174df537 - 09234f0e5 trivial change to remove -UseCompressedOops option from script Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/09234f0e Tree:

kafka git commit: Revert kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 059b09dec - 0b312a6b9 Revert kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

Git Push Summary

2015-01-19 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [deleted] b0c7d579f

Git Push Summary

2015-01-19 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [created] 058d58ade refs/tags/show [created] b0c7d579f

svn commit: r1653131 - /kafka/site/KEYS

2015-01-19 Thread junrao
Author: junrao Date: Mon Jan 19 22:00:16 2015 New Revision: 1653131 URL: http://svn.apache.org/r1653131 Log: move KEYS from top level to site since top level is readonly now Added: kafka/site/KEYS Added: kafka/site/KEYS URL: http://svn.apache.org/viewvc/kafka/site/KEYS?rev=1653131view=auto

kafka git commit: KAFKA-1879; Log warning when receiving produce requests with acks 1; patched by Gwen Shapira; reviewed by Jun Rao

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 1e640177f - 059b09dec KAFKA-1879; Log warning when receiving produce requests with acks 1; patched by Gwen Shapira; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1723; num.partitions documented default is 1 while actual default is 2; patched by Manikumar Reddy; reviewed by Jun Rao

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 86a8bc2b0 - 7013b2639 KAFKA-1723; num.partitions documented default is 1 while actual default is 2; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1723; num.partitions documented default is 1 while actual default is 2; patched by Manikumar Reddy; reviewed by Jun Rao

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 09234f0e5 - 49d7f8ee1 KAFKA-1723; num.partitions documented default is 1 while actual default is 2; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1876; pom file for scala 2.11 should reference a specific version; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 7013b2639 - 1e640177f KAFKA-1876; pom file for scala 2.11 should reference a specific version; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1876; pom file for scala 2.11 should reference a specific version; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani

2015-01-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 07cff7636 - 5d648cfdb KAFKA-1876; pom file for scala 2.11 should reference a specific version; patched by Jun Rao; reviewed by Joe Stein and Sriharsha Chintalapani Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy

2015-01-15 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 45697ed6c - 602d572f6 kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

svn commit: r1653422 - /kafka/site/082/configuration.html

2015-01-20 Thread junrao
Author: junrao Date: Wed Jan 21 02:16:57 2015 New Revision: 1653422 URL: http://svn.apache.org/r1653422 Log: update default config value for 0.8.2 Modified: kafka/site/082/configuration.html Modified: kafka/site/082/configuration.html URL: http://svn.apache.org/viewvc/kafka/site/082

kafka git commit: kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy

2015-01-15 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 a643be62a - 17c8bdcbb kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

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

2015-02-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk d5fbba633 - f5684366e kafka-1952; High CPU Usage in 0.8.2 release; patched by Jun Rao; reviewed by Guozhang Wang, Ewen Cheslack-Postava and Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1902; fix MetricName so that Yammer reporter can work correctly; patched by Jun Rao; reviewed by Manikumar Reddy, Manikumar Reddy and Joel Koshy

2015-01-28 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 0b312a6b9 - 2a1e3d451 KAFKA-1902; fix MetricName so that Yammer reporter can work correctly; patched by Jun Rao; reviewed by Manikumar Reddy, Manikumar Reddy and Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

kafka git commit: KAFKA-1729; Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; patched by Joel Koshy; reviewed by Jun Rao

2015-01-28 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 2a1e3d451 - 96ce96dc9 KAFKA-1729; Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; patched by Joel Koshy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-1861; Publishing kafka-client:test in order to utilize the helper utils in TestUtils; patched by Manikumar Reddy; reviewed by Jun Rao

2015-01-28 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 96ce96dc9 - 7130da90a KAFKA-1861; Publishing kafka-client:test in order to utilize the helper utils in TestUtils; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

Git Push Summary

2015-01-28 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [created] 223ac42a7

kafka git commit: kafka-1797; (addressing Manikumar Reddy's comment) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Manikumar Reddy and Neha Narkhede

2015-01-09 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk f82518a85 - a93ef199b kafka-1797; (addressing Manikumar Reddy's comment) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Manikumar Reddy and Neha Narkhede Project:

kafka git commit: kafka-1851; OffsetFetchRequest returns extra partitions when input only contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede

2015-01-09 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk a93ef199b - e52a6181b kafka-1851; OffsetFetchRequest returns extra partitions when input only contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1851; OffsetFetchRequest returns extra partitions when input only contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede

2015-01-09 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 f71933ef1 - f88db16d1 kafka-1851; OffsetFetchRequest returns extra partitions when input only contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

svn commit: r1650694 - /kafka/site/082/ops.html

2015-01-09 Thread junrao
Author: junrao Date: Fri Jan 9 23:21:15 2015 New Revision: 1650694 URL: http://svn.apache.org/r1650694 Log: update jmx metrics name for 0.8.2 Modified: kafka/site/082/ops.html Modified: kafka/site/082/ops.html URL: http://svn.apache.org/viewvc/kafka/site/082/ops.html?rev=1650694r1

kafka git commit: kafka-1797; (follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Jay Kreps

2015-01-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 53329583a - f32e5ce24 kafka-1797; (follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Jay Kreps Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1797; (follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Jay Kreps

2015-01-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 4471dc08b - 50b734690 kafka-1797; (follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Jay Kreps Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1797; (delta follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede

2015-01-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 50b734690 - 517503db2 kafka-1797; (delta follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1797; (delta follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede

2015-01-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 f32e5ce24 - fec9f32da kafka-1797; (delta follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao

2015-01-13 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 432d397af - 4e584deeb kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao

2015-01-13 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk e79ebdfe2 - bfb2da3c8 trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bfb2da3c Tree:

kafka git commit: trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao

2015-01-13 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 4e584deeb - d4629df1c trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d4629df1 Tree:

Git Push Summary

2015-01-13 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [deleted] b1565f1a1

kafka git commit: change build version to 0.8.2.0

2015-01-13 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 d4629df1c - a643be62a change build version to 0.8.2.0 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a643be62 Tree:

Git Push Summary

2015-01-13 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [created] b0c7d579f

Git Push Summary

2015-01-13 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.0 [created] b1565f1a1

kafka git commit: KAFKA-1841; OffsetCommitRequest API - timestamp field is not versioned; patched by Jun Rao; reviewed by Joel Koshy

2015-01-12 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 9b6744d3a - 432d397af KAFKA-1841; OffsetCommitRequest API - timestamp field is not versioned; patched by Jun Rao; reviewed by Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1797; (missed parametric in a few files) add the serializer/deserializer api to the new java client; patched by Jun Rao

2015-01-12 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 8d5d45904 - 828b808f9 kafka-1797; (missed parametric in a few files) add the serializer/deserializer api to the new java client; patched by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/2] kafka git commit: KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao

2015-01-12 Thread junrao
KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/688e38ce Tree:

[2/2] kafka git commit: KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao

2015-01-12 Thread junrao
KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9b6744d3 Tree:

[1/2] kafka git commit: KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao

2015-01-12 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 828b808f9 - 9b6744d3a http://git-wip-us.apache.org/repos/asf/kafka/blob/9b6744d3/clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java -- diff --git

kafka git commit: kafka-1797; (missed parametric in a few files) add the serializer/deserializer api to the new java client; patched by Jun Rao

2015-01-12 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 14779dddb - 6f4dea9db kafka-1797; (missed parametric in a few files) add the serializer/deserializer api to the new java client; patched by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: change build version to 0.8.2.1

2015-02-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 45b9e1580 - cd8f0b87b change build version to 0.8.2.1 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cd8f0b87 Tree:

Git Push Summary

2015-02-18 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.1 [created] c1b4c5853

svn commit: r8222 - in /release/kafka/0.8.2.1: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ javad

2015-03-09 Thread junrao
Author: junrao Date: Mon Mar 9 18:29:48 2015 New Revision: 8222 Log: Apache Kafka 0.8.2.1 release [This commit notification would consist of 314 parts, which exceeds the limit of 50 ones, so it was shortened to the summary.]

svn commit: r1665965 - /kafka/site/downloads.html

2015-03-11 Thread junrao
Author: junrao Date: Wed Mar 11 18:54:40 2015 New Revision: 1665965 URL: http://svn.apache.org/r1665965 Log: add 0.8.2.1 download links Modified: kafka/site/downloads.html Modified: kafka/site/downloads.html URL: http://svn.apache.org/viewvc/kafka/site/downloads.html?rev=1665965r1

kafka git commit: kafka-527; Compression support does numerous byte copies; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao

2015-03-25 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk eb2100876 - a74688de4 kafka-527; Compression support does numerous byte copies; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2044; Support requests and responses from o.a.k.common in KafkaApis; patched by Gwen Shapira; reviewed by Jun Rao

2015-03-28 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk c5df2a8e3 - d8fe98efe kafka-2044; Support requests and responses from o.a.k.common in KafkaApis; patched by Gwen Shapira; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

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

2015-02-23 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 3f1e08822 - 41189ea56 kafka-1971; starting a broker with a conflicting id will delete the previous broker registration; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

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

2015-02-23 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.8.2 bafecc936 - 5f3eb1caf kafka-1971; starting a broker with a conflicting id will delete the previous broker registration; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

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

2015-02-24 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 7c82afddc - 10311c138 kafka-1984; java producer may miss an available partition; patched by Jun Rao; reviewed by Ewen Cheslack-Postava, Jay Kreps, and Guozhang Wang Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

2015-02-26 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk b8904e961 - ef252dea7 kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

Git Push Summary

2015-02-26 Thread junrao
Repository: kafka Updated Tags: refs/tags/0.8.2.1 [created] bd1bfb63e

kafka git commit: kafka-1400; transient unit test failure in SocketServerTest; patched by Jun Rao; reviewed by Ewen Cheslack-Postava and Jiangjie Qin

2015-02-26 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk ef252dea7 - e39373d16 kafka-1400; transient unit test failure in SocketServerTest; patched by Jun Rao; reviewed by Ewen Cheslack-Postava and Jiangjie Qin Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2013; benchmark test for the purgatory; patched by Yasuhiro Matsuda; reviewed by Jun Rao

2015-04-01 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 66c6f9b1c - 619d78eb5 kafka-2013; benchmark test for the purgatory; patched by Yasuhiro Matsuda; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2016; RollingBounceTest takes long; patched by Ted Malaska; reviewed by Jun Rao

2015-04-02 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 619d78eb5 - ad722531d kafka-2016; RollingBounceTest takes long; patched by Ted Malaska; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ad722531

kafka git commit: kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen Wang; reviewed by Jun Rao

2015-04-08 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 6880f66c9 - 194d1fc03 kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen Wang; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1989; New purgatory design; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao

2015-04-08 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk d3aa99c54 - 6880f66c9 kafka-1989; New purgatory design; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2118; Cleaner cannot clean after shutdown during replaceSegments; patched by Rajini Sivaram; reviewed by Jun Rao

2015-04-26 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk ba3e08958 - dbfe8c0a7 kafka-2118; Cleaner cannot clean after shutdown during replaceSegments; patched by Rajini Sivaram; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2113; TestPurgatoryPerformance does not compile using IBM JDK; patched by Rajini Sivaram; reviewed by Yasuhiro Matsuda and Jun Rao

2015-04-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk bfbd3acbf - 5397d3c53 kafka-2113; TestPurgatoryPerformance does not compile using IBM JDK; patched by Rajini Sivaram; reviewed by Yasuhiro Matsuda and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2043; CompressionType is passed in each RecordAccumulator append; patched by Grant Henke; reviewed by Jun Rao

2015-04-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 9c23d9355 - 75e1cc8bc kafka-2043; CompressionType is passed in each RecordAccumulator append; patched by Grant Henke; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2099; BrokerEndPoint file, methods and object names should match; patched by Gwen Shapira; reviewed by Sriharsha Chintalapani and Jun Rao

2015-04-06 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 75e1cc8bc - 04fce48e1 kafka-2099; BrokerEndPoint file, methods and object names should match; patched by Gwen Shapira; reviewed by Sriharsha Chintalapani and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[1/3] kafka git commit: kafka-1926; Replace kafka.utils.Utils with o.a.k.common.utils.Utils; patched by Tong Li; reviewed by Jun Rao

2015-04-05 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 53f31432a - 9c23d9355 http://git-wip-us.apache.org/repos/asf/kafka/blob/9c23d935/core/src/test/scala/kafka/tools/TestLogCleaning.scala -- diff --git

[2/3] kafka git commit: kafka-1926; Replace kafka.utils.Utils with o.a.k.common.utils.Utils; patched by Tong Li; reviewed by Jun Rao

2015-04-05 Thread junrao
http://git-wip-us.apache.org/repos/asf/kafka/blob/9c23d935/core/src/main/scala/kafka/tools/TestLogCleaning.scala -- diff --git a/core/src/main/scala/kafka/tools/TestLogCleaning.scala

svn commit: r1671461 - in /kafka/site/083: configuration.html upgrade.html

2015-04-05 Thread junrao
Author: junrao Date: Mon Apr 6 00:38:03 2015 New Revision: 1671461 URL: http://svn.apache.org/r1671461 Log: update new 0.8.3 config inter.broker.protocol.version and upgrade path Modified: kafka/site/083/configuration.html kafka/site/083/upgrade.html Modified: kafka/site/083

[1/3] kafka git commit: kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao

2015-04-05 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 07598ad8a - 53f31432a http://git-wip-us.apache.org/repos/asf/kafka/blob/53f31432/core/src/test/scala/unit/kafka/server/KafkaConfigConfigDefTest.scala -- diff --git

[2/3] kafka git commit: kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao

2015-04-05 Thread junrao
http://git-wip-us.apache.org/repos/asf/kafka/blob/53f31432/core/src/main/scala/kafka/server/KafkaConfig.scala -- diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala

[3/3] kafka git commit: kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao

2015-04-05 Thread junrao
kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/53f31432 Tree:

[3/3] kafka git commit: kafka-1926; Replace kafka.utils.Utils with o.a.k.common.utils.Utils; patched by Tong Li; reviewed by Jun Rao

2015-04-05 Thread junrao
kafka-1926; Replace kafka.utils.Utils with o.a.k.common.utils.Utils; patched by Tong Li; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9c23d935 Tree:

kafka git commit: kafka-1992; checkEnoughReplicasReachOffset doesn't need to get requiredAcks; patched by Gwen Shapira; reviewed by Jeff Holoman, Jiangjie Qin and Jun Rao

2015-04-07 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk b1cc72510 - d9ab917dc kafka-1992; checkEnoughReplicasReachOffset doesn't need to get requiredAcks; patched by Gwen Shapira; reviewed by Jeff Holoman, Jiangjie Qin and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

kafka git commit: kafka-1517; Messages is a required argument to Producer Performance Test; patched by Daniel Compton; reviewed by Jun Rao

2015-04-07 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 06a26656f - fef709d51 kafka-1517; Messages is a required argument to Producer Performance Test; patched by Daniel Compton; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/3] kafka git commit: kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, G

2015-06-03 Thread junrao
http://git-wip-us.apache.org/repos/asf/kafka/blob/78ba492e/clients/src/main/java/org/apache/kafka/common/network/Selector.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/network/Selector.java

[1/3] kafka git commit: kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, G

2015-06-03 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk d22987f01 - 78ba492e3 http://git-wip-us.apache.org/repos/asf/kafka/blob/78ba492e/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala -- diff --git

[3/3] kafka git commit: kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, G

2015-06-03 Thread junrao
kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, Guozhang Wang and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk cf28f8939 - dc54055d0 kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 16ecf9806 - cf28f8939 kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-1758; corrupt recovery file prevents startup; patched by Manikumar Reddy; reviewed by Neha Narkhede and Jun Rao

2015-06-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 1c93bb16a - 19c98cb8e kafka-1758; corrupt recovery file prevents startup; patched by Manikumar Reddy; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2012; Broker should automatically handle corrupt index files; patched by Manikumar Reddy; reviewed by Jun Rao

2015-06-19 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk ca758252c - 16ecf9806 kafka-2012; Broker should automatically handle corrupt index files; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/2] kafka git commit: kafka-2249; KafkaConfig does not preserve original Properties; patched by Gwen Shapira; reviewed by Jun Rao

2015-06-18 Thread junrao
kafka-2249; KafkaConfig does not preserve original Properties; patched by Gwen Shapira; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5c904074 Tree:

[1/2] kafka git commit: kafka-2249; KafkaConfig does not preserve original Properties; patched by Gwen Shapira; reviewed by Jun Rao

2015-06-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk ba86f0a25 - 5c9040745 http://git-wip-us.apache.org/repos/asf/kafka/blob/5c904074/core/src/test/scala/unit/kafka/log/LogConfigTest.scala -- diff --git

[1/2] kafka git commit: kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Post

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 2270a7537 - b6d326b08 http://git-wip-us.apache.org/repos/asf/kafka/blob/b6d326b0/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java -- diff --git

[2/2] kafka git commit: kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Post

2015-06-22 Thread junrao
kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Postava, Guozhang Wang and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2265; creating a topic with large number of partitions takes a long time; patched by Manikumar Reddy; reviewed by Jun Rao

2015-06-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 5c9040745 - d9c0ad685 kafka-2265; creating a topic with large number of partitions takes a long time; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2234; Partition reassignment of a nonexistent topic prevents future reassignments; patched by Manikumar Reddy; reviewed by Jun Rao

2015-06-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk d9c0ad685 - 5c2ca30f2 kafka-2234; Partition reassignment of a nonexistent topic prevents future reassignments; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: trivial change to fix unit test failure introduced in kafka-2234

2015-06-18 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 5c2ca30f2 - 1c93bb16a trivial change to fix unit test failure introduced in kafka-2234 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1c93bb16 Tree:

kafka git commit: kafka-2195; Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest; patched by Andrii Biletskyi; reviewed by Jun Rao

2015-06-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 20a31a29f - 54e54f080 kafka-2195; Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest; patched by Andrii Biletskyi; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2272; listeners endpoint parsing fails if the hostname has capital letter; patched by Sriharsha Chintalapani; reviewed by Jun Rao

2015-06-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 395716ebf - 28ecea421 kafka-2272; listeners endpoint parsing fails if the hostname has capital letter; patched by Sriharsha Chintalapani; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2270; incorrect package name in unit tests; patched by Proneet Verma; reviewed by Jun Rao

2015-06-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 54e54f080 - 395716ebf kafka-2270; incorrect package name in unit tests; patched by Proneet Verma; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2262; LogSegmentSize validation should be consistent; patched by Manikumar Reddy; reviewed by Jun Rao

2015-06-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 478505632 - 9650e12df kafka-2262; LogSegmentSize validation should be consistent; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[1/2] kafka git commit: kafka-2264; SESSION_TIMEOUT_MS_CONFIG in ConsumerConfig should be int; patched by Manikumar Reddy; reviewed by Jun Rao

2015-06-16 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 28ecea421 - 478505632 kafka-2264; SESSION_TIMEOUT_MS_CONFIG in ConsumerConfig should be int; patched by Manikumar Reddy; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/2] kafka git commit: kafka-2252; Socket connection closing is logged, but not corresponding opening of socket; patched by Gwen Shapira; reviewed by Jun Rao

2015-06-16 Thread junrao
kafka-2252; Socket connection closing is logged, but not corresponding opening of socket; patched by Gwen Shapira; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/47850563 Tree:

kafka git commit: kafka-2232; make MockProducer generic; patched by Alexander Pakulov; reviewed by Jun Rao

2015-06-12 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 017c00caf - d31a2c238 kafka-2232; make MockProducer generic; patched by Alexander Pakulov; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d31a2c23

<    1   2   3   4   5   6   7   8   9   10   >