[4/5] git commit: ApiUtils#writeShortString uses String length instead of byte length; kafka-680; patched by David Arthur; reviewed by Jun Rao

2013-01-04 Thread junrao
ApiUtils#writeShortString uses String length instead of byte length; kafka-680; patched by David Arthur; 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/2f4bfc64 Tree:

[1/5] git commit: KAFKA-675 Allow the user to override the host that we bind to. Patch from Matan Amirmatan.a...@voxer.com with slight changes to improve error messages for a bad host or port.

2013-01-04 Thread junrao
KAFKA-675 Allow the user to override the host that we bind to. Patch from Matan Amirmatan.a...@voxer.com with slight changes to improve error messages for a bad host or port. Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/5] git commit: KAFKA-668 Store jmx port in broker zk string - controlled shutdown admin tool should not require controller JMX url/port to be supplied. Reviewed by Jun Rao.

2013-01-04 Thread junrao
KAFKA-668 Store jmx port in broker zk string - controlled shutdown admin tool should not require controller JMX url/port to be supplied. 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/25d77cc6 Tree:

git commit: ConsumerOffsetChecker does not work with 0.8; kafka-685; patched by Maxime Brugidou; reviewed by Jun Rao

2013-01-08 Thread junrao
Updated Branches: refs/heads/0.8 2f4bfc645 - fd94251d8 ConsumerOffsetChecker does not work with 0.8; kafka-685; patched by Maxime Brugidou; 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/fd94251d

git commit: Fault tolerance broken with replication factor 1; kafka-691; patched by Maxime Brugidou; reviewed by Jun Rao

2013-01-10 Thread junrao
Updated Branches: refs/heads/0.8 ddd66cbd8 - b71e6dc35 Fault tolerance broken with replication factor 1; kafka-691; patched by Maxime Brugidou; 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/b71e6dc3

[4/11] git commit: KAFKA-133 publish kafka to maven - patch by Maxime Brugidou with updates for depen by Otis Gospodnetic, reviewed by Joe Stein

2013-01-11 Thread junrao
KAFKA-133 publish kafka to maven - patch by Maxime Brugidou with updates for depen by Otis Gospodnetic, reviewed by Joe Stein Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ddd66cbd Tree:

git commit: ConsoleProducer does not exit correctly; kafka-701; patched by Maxime Brugidou; reviewed by Jun Rao

2013-01-14 Thread junrao
Updated Branches: refs/heads/0.8 c02e7fd69 - 53818bb7e ConsoleProducer does not exit correctly; kafka-701; patched by Maxime Brugidou; 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/53818bb7 Tree:

[1/2] git commit: ConsoleConsumer throws InvalidConfigException; kafka-697; patched by Swapnil Ghike; reviewed by Jun Rao

2013-01-15 Thread junrao
ConsoleConsumer throws InvalidConfigException; kafka-697; patched by Swapnil Ghike; 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/b2eec991 Tree:

git commit: Disallow clients to set replicaId in FetchRequest; kafka-699; patched by Jun Rao; reviewed by Neha Narkhede

2013-01-15 Thread junrao
Updated Branches: refs/heads/0.8 de1a4d727 - 777f66220 Disallow clients to set replicaId in FetchRequest; kafka-699; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/777f6622

git commit: Consumer rebalance fails if no leader available for a partition and stops all fetchers; patched by Maxime Brugidou; reviewed by Jun Rao; kafka-693

2013-01-17 Thread junrao
Updated Branches: refs/heads/0.8 da7f14676 - 214a0af46 Consumer rebalance fails if no leader available for a partition and stops all fetchers; patched by Maxime Brugidou; reviewed by Jun Rao; kafka-693 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[5/7] git commit: KAFKA-702 Deadlock between request handler/processor threads; reviewed by Neha Narkhede, Jun Rao

2013-01-17 Thread junrao
KAFKA-702 Deadlock between request handler/processor threads; reviewed by Neha Narkhede, Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/da7f1467 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/da7f1467 Diff:

[1/7] git commit: KAFKA-697 ConsoleConsumer throws InvalidConfigException for . in client id; reviewed by Jun Rao, Neha Narkhede, John Fung

2013-01-17 Thread junrao
KAFKA-697 ConsoleConsumer throws InvalidConfigException for . in client id; reviewed by Jun Rao, Neha Narkhede, John Fung Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/eeb817ac Tree:

[24/28] git commit: KAFKA-696 Fix toString() API for all requests to make logging easier to read; reviewed by Neha Narkhede, Jun Rao

2013-01-25 Thread junrao
KAFKA-696 Fix toString() API for all requests to make logging easier to read; reviewed by Neha Narkhede, Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8d41620a Tree:

[23/28] git commit: KAFKA-720 Migration tool halts silently; reviewed by Neha Narkhede

2013-01-25 Thread junrao
KAFKA-720 Migration tool halts silently; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a15f1f2d Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a15f1f2d Diff:

[21/28] git commit: KAFKA-731 use a variable for the ivy2 path in kafka-run-class.sh patch by Joe Stein reviewed by Neha Narkhede

2013-01-25 Thread junrao
KAFKA-731 use a variable for the ivy2 path in kafka-run-class.sh patch by Joe Stein reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cb3359f9 Tree:

[15/28] git commit: KAFKA-708 ISR becomes empty while marking a partition offline; reviewed by Jun Rao

2013-01-25 Thread junrao
KAFKA-708 ISR becomes empty while marking a partition offline; 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/eb0d5a7f Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/eb0d5a7f Diff:

[22/28] git commit: Minor log4j fix in the producer

2013-01-25 Thread junrao
Minor log4j fix in the producer Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8e7effc0 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8e7effc0 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8e7effc0

[10/28] git commit: KAFKA-139 cross-compile multiple Scala versions the dependency jars moved and the bin scripts needed to point to the new locations

2013-01-25 Thread junrao
KAFKA-139 cross-compile multiple Scala versions the dependency jars moved and the bin scripts needed to point to the new locations Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5e3e181a Tree:

[3/28] git commit: draft patch

2013-01-25 Thread junrao
draft patch Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/aa1546b0 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/aa1546b0 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/aa1546b0 Branch: refs/heads/trunk

[34/37] git commit: KAFKA-776 Changing ZK format breaks some tools; reviewed by Neha Narkhede

2013-03-03 Thread junrao
KAFKA-776 Changing ZK format breaks some tools; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cea27356 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cea27356 Diff:

[27/37] git commit: KAFKA-734 Migration tool needs a revamp, it was poorly written and has many performance bugs; reviewed by Jun Rao

2013-03-03 Thread junrao
KAFKA-734 Migration tool needs a revamp, it was poorly written and has many performance bugs; 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/d925b157 Tree:

[23/37] git commit: standardizing json values stored in ZK; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-755

2013-03-03 Thread junrao
standardizing json values stored in ZK; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-755 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/828ce83d Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/828ce83d Diff:

[8/37] git commit: Follow up to KAFKA-695:Broker shuts down due to attempt to read a closed index file, reviewed by Neha and Jay

2013-03-03 Thread junrao
Follow up to KAFKA-695:Broker shuts down due to attempt to read a closed index file, reviewed by Neha and Jay Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/814c9709 Tree:

[4/37] git commit: KAFKA-713 Update Hadoop producer for Kafka 0.8 changes; reviewed by Neha Narkhede

2013-03-03 Thread junrao
KAFKA-713 Update Hadoop producer for Kafka 0.8 changes; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/295734f6 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/295734f6 Diff:

[3/37] git commit: System Test : Disable shallow.iterator in Mirror Maker test cases to make compression work correctly; patched by John Fung; reviewed by Jun Rao; kafka-737

2013-03-03 Thread junrao
System Test : Disable shallow.iterator in Mirror Maker test cases to make compression work correctly; patched by John Fung; reviewed by Jun Rao; kafka-737 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2ae06902 Tree:

[24/37] git commit: KAFKA-736 Add an option to the 0.8 producer to mimic 0.7 producer behavior; reviewed by Jun Rao and Sriram Subramanian

2013-03-03 Thread junrao
KAFKA-736 Add an option to the 0.8 producer to mimic 0.7 producer behavior; reviewed by Jun Rao and Sriram Subramanian Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4d8fb1ee Tree:

[16/37] git commit: Fix windows build script - kafka-run-class.bat; patched by Mark deVilliers; reviewed by Jun Rao; kafka-751

2013-03-03 Thread junrao
Fix windows build script - kafka-run-class.bat; patched by Mark deVilliers; reviewed by Jun Rao; kafka-751 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b84168a3 Tree:

[20/37] git commit: KAFKA-770 KafkaConfig properties should be verified in the constructor; reviewed by Neha Narkhede

2013-03-03 Thread junrao
KAFKA-770 KafkaConfig properties should be verified in the constructor; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b056a9a1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b056a9a1

[17/37] git commit: startHighWaterMarksCheckPointThread is never called; patched by Sriram Subramanian; reviewed by Jun Rao; kafka-758

2013-03-03 Thread junrao
startHighWaterMarksCheckPointThread is never called; patched by Sriram Subramanian; reviewed by Jun Rao; kafka-758 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/30f992c5 Tree:

[22/37] git commit: KAFKA-769 On startup, a brokers highwatermark for every topic partition gets reset to zero; reviewed by Neha Narkhede

2013-03-03 Thread junrao
KAFKA-769 On startup, a brokers highwatermark for every topic partition gets reset to zero; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/144a0a2a Tree:

[7/37] git commit: KAFKA-749 Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed; reviewed by Sriram and Jay Kreps

2013-03-03 Thread junrao
KAFKA-749 Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed; reviewed by Sriram and Jay Kreps Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/826f02a7 Tree:

git commit: System Test Transient Failure on testcase_0122; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede; kafka-772

2013-03-04 Thread junrao
Updated Branches: refs/heads/0.8 92ecebecd - 0ee46e05d System Test Transient Failure on testcase_0122; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede; kafka-772 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: Include controllerId in all requests sent by controller; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-793

2013-03-07 Thread junrao
Updated Branches: refs/heads/0.8 771760ce2 - 19ae1959b Include controllerId in all requests sent by controller; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-793 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[1/3] kafka-792; Update multiple attributes in testcase_xxxx_properties.json; patched by John Fung; reviewed by Jun Rao

2013-03-08 Thread junrao
http://git-wip-us.apache.org/repos/asf/kafka/blob/b5edbb19/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json -- diff --git

git commit: kafka-801; Fix MessagesInPerSec mbean to count uncompressed message rate; patched by Jun Rao; reviewed by Neha Narkhede

2013-03-13 Thread junrao
Updated Branches: refs/heads/0.8 290d5e0ea - dd9676163 kafka-801; Fix MessagesInPerSec mbean to count uncompressed message rate; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-763 delta; Add an option to replica from the largest offset during unclean leader election; patched by Swapnil Ghike; reviewed by Jun Rao

2013-03-13 Thread junrao
Updated Branches: refs/heads/0.8 0a9283530 - 3b3fb7fed kafka-763 delta; Add an option to replica from the largest offset during unclean leader election; patched by Swapnil Ghike; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: Incorrect index in the log of a follower; patched by Jun Rao; reviewed by Neha Narkhede and Jay Kreps; kafka-804

2013-03-18 Thread junrao
Updated Branches: refs/heads/0.8 d40d255bc - 46ebdc16e Incorrect index in the log of a follower; patched by Jun Rao; reviewed by Neha Narkhede and Jay Kreps; kafka-804 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: Support deep iteration in DumpLogSegments tool; patched by Jun Rao; reviewed by Neha Narkhede; kafka-812

2013-03-19 Thread junrao
Updated Branches: refs/heads/0.8 46ebdc16e - a376f9221 Support deep iteration in DumpLogSegments tool; patched by Jun Rao; reviewed by Neha Narkhede; kafka-812 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a376f922

git commit: kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao

2013-03-25 Thread junrao
Updated Branches: refs/heads/0.8 28ee78553 - df221297c kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede

2013-03-25 Thread junrao
Updated Branches: refs/heads/0.8 df221297c - e367f3ffb kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao

2013-03-27 Thread junrao
Updated Branches: refs/heads/0.8 c5e354d3a - f570cce1f kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos Manolescu; reviewed by Jun Rao

2013-03-29 Thread junrao
Updated Branches: refs/heads/0.8 9f6af315c - 68528dafa kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos Manolescu; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: trivial fix to print key properly in DumpLogSegments

2013-03-29 Thread junrao
Updated Branches: refs/heads/0.8 68528dafa - 06911384f trivial fix to print key properly in DumpLogSegments Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/06911384 Tree:

git commit: kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede

2013-04-01 Thread junrao
Updated Branches: refs/heads/0.8 a9ce73cfd - 3c27988ca kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3c27988c Tree:

git commit: kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede

2013-04-03 Thread junrao
Updated Branches: refs/heads/0.8 bd262ac70 - 5a50f7e55 kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-861; IndexOutOfBoundsException while fetching data from leader; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede

2013-04-15 Thread junrao
Updated Branches: refs/heads/0.8 158baf661 - b29b6296a kafka-861; IndexOutOfBoundsException while fetching data from leader; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[07/27] git commit: Include controllerId in all requests sent by controller; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-793

2013-04-17 Thread junrao
Include controllerId in all requests sent by controller; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-793 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/19ae1959 Tree:

[03/27] git commit: Use withRequiredArg while parsing jopt options in all tools; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-786

2013-04-17 Thread junrao
Use withRequiredArg while parsing jopt options in all tools; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-786 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2e64c6a5 Tree:

[25/27] git commit: KAFKA-820 Topic metadata request handling fails to return all metadata about replicas; reviewed by Jun Rao

2013-04-17 Thread junrao
KAFKA-820 Topic metadata request handling fails to return all metadata about replicas; 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/08b2a37c Tree:

[06/27] git commit: MirrorMaker with shallow.iterator.enable=true produces unreadble messages; patched by Jun Rao; reviewed by Neha Narkhede; kafka-732

2013-04-17 Thread junrao
MirrorMaker with shallow.iterator.enable=true produces unreadble messages; patched by Jun Rao; reviewed by Neha Narkhede; kafka-732 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/771760ce Tree:

[09/27] kafka-792; Update multiple attributes in testcase_xxxx_properties.json; patched by John Fung; reviewed by Jun Rao

2013-04-17 Thread junrao
http://git-wip-us.apache.org/repos/asf/kafka/blob/b5edbb19/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json -- diff --git

[21/27] git commit: Incorrect index in the log of a follower; patched by Jun Rao; reviewed by Neha Narkhede and Jay Kreps; kafka-804

2013-04-17 Thread junrao
Incorrect index in the log of a follower; patched by Jun Rao; reviewed by Neha Narkhede and Jay Kreps; kafka-804 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/46ebdc16 Tree:

[15/27] git commit: kafka-801; Fix MessagesInPerSec mbean to count uncompressed message rate; patched by Jun Rao; reviewed by Neha Narkhede

2013-04-17 Thread junrao
kafka-801; Fix MessagesInPerSec mbean to count uncompressed message rate; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/dd967616 Tree:

[23/27] git commit: KAFKA-815 Improve SimpleConsumerShell to take in a max messages config option; reviewed by Jun Rao

2013-04-17 Thread junrao
KAFKA-815 Improve SimpleConsumerShell to take in a max messages config option;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/a737986e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a737986e

git commit: kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao

2013-04-25 Thread junrao
Updated Branches: refs/heads/0.8 ede85875a - 2d7403174 kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; 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/2d740317 Tree:

git commit: kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede

2013-04-25 Thread junrao
Updated Branches: refs/heads/0.8 2d7403174 - 6e640e355 kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

svn commit: r1476865 [2/2] - in /kafka/site: ./ 07/ 07/images/ 07/includes/ images/ includes/

2013-04-28 Thread junrao
Added: kafka/site/07/quickstart.html URL: http://svn.apache.org/viewvc/kafka/site/07/quickstart.html?rev=1476865view=auto == --- kafka/site/07/quickstart.html (added) +++ kafka/site/07/quickstart.html Sun Apr 28 23:50:07

svn commit: r1476866 - /kafka/site/07/includes/header.html

2013-04-28 Thread junrao
Author: junrao Date: Sun Apr 28 23:56:10 2013 New Revision: 1476866 URL: http://svn.apache.org/r1476866 Log: minor format change Modified: kafka/site/07/includes/header.html Modified: kafka/site/07/includes/header.html URL: http://svn.apache.org/viewvc/kafka/site/07/includes/header.html

svn commit: r1476887 - /kafka/site/08/configuration.html

2013-04-28 Thread junrao
Author: junrao Date: Mon Apr 29 04:16:53 2013 New Revision: 1476887 URL: http://svn.apache.org/r1476887 Log: minor changes to 0.8 docs Modified: kafka/site/08/configuration.html Modified: kafka/site/08/configuration.html URL: http://svn.apache.org/viewvc/kafka/site/08/configuration.html

svn commit: r1476890 - /kafka/site/08/configuration.html

2013-04-28 Thread junrao
Author: junrao Date: Mon Apr 29 04:30:25 2013 New Revision: 1476890 URL: http://svn.apache.org/r1476890 Log: add nowrap to 0.8 docs Modified: kafka/site/08/configuration.html Modified: kafka/site/08/configuration.html URL: http://svn.apache.org/viewvc/kafka/site/08/configuration.html?rev

svn commit: r1476891 - /kafka/site/07/configuration.html

2013-04-28 Thread junrao
Author: junrao Date: Mon Apr 29 04:39:56 2013 New Revision: 1476891 URL: http://svn.apache.org/r1476891 Log: add log.roll.hours to 0.7 configw Modified: kafka/site/07/configuration.html Modified: kafka/site/07/configuration.html URL: http://svn.apache.org/viewvc/kafka/site/07

svn commit: r1477138 - /kafka/site/08/api.html

2013-04-29 Thread junrao
Author: junrao Date: Mon Apr 29 15:13:35 2013 New Revision: 1477138 URL: http://svn.apache.org/r1477138 Log: add high level consumer example to 0.8 doc Modified: kafka/site/08/api.html Modified: kafka/site/08/api.html URL: http://svn.apache.org/viewvc/kafka/site/08/api.html?rev=1477138r1

svn commit: r1477141 - /kafka/site/08/api.html

2013-04-29 Thread junrao
Author: junrao Date: Mon Apr 29 15:16:14 2013 New Revision: 1477141 URL: http://svn.apache.org/r1477141 Log: minor change to 0.8 doc Modified: kafka/site/08/api.html Modified: kafka/site/08/api.html URL: http://svn.apache.org/viewvc/kafka/site/08/api.html?rev=1477141r1=1477140r2

svn commit: r1477910 - /kafka/site/08/tools.html

2013-04-30 Thread junrao
Author: junrao Date: Wed May 1 04:24:33 2013 New Revision: 1477910 URL: http://svn.apache.org/r1477910 Log: add a link to 0.8 adminstrative tools Modified: kafka/site/08/tools.html Modified: kafka/site/08/tools.html URL: http://svn.apache.org/viewvc/kafka/site/08/tools.html?rev=1477910r1

svn commit: r1478066 - in /kafka/site/08: api.html configuration.html includes/header.html quickstart.html

2013-05-01 Thread junrao
Author: junrao Date: Wed May 1 16:05:06 2013 New Revision: 1478066 URL: http://svn.apache.org/r1478066 Log: fix typos in 0.8 docs Modified: kafka/site/08/api.html kafka/site/08/configuration.html kafka/site/08/includes/header.html kafka/site/08/quickstart.html Modified: kafka

svn commit: r1478272 - /kafka/site/08/includes/header.html

2013-05-01 Thread junrao
Author: junrao Date: Thu May 2 05:25:16 2013 New Revision: 1478272 URL: http://svn.apache.org/r1478272 Log: fix change in 0.8 docs Modified: kafka/site/08/includes/header.html Modified: kafka/site/08/includes/header.html URL: http://svn.apache.org/viewvc/kafka/site/08/includes/header.html

svn commit: r1485258 - in /kafka/site: 07/configuration.html 08/quickstart.html

2013-05-22 Thread junrao
Author: junrao Date: Wed May 22 15:50:22 2013 New Revision: 1485258 URL: http://svn.apache.org/r1485258 Log: add missing config property in 0.7; clarify quickstart in 0.8 Modified: kafka/site/07/configuration.html kafka/site/08/quickstart.html Modified: kafka/site/07/configuration.html

svn commit: r1485260 - /kafka/site/08/quickstart.html

2013-05-22 Thread junrao
Author: junrao Date: Wed May 22 15:52:23 2013 New Revision: 1485260 URL: http://svn.apache.org/r1485260 Log: minor bug fix Modified: kafka/site/08/quickstart.html Modified: kafka/site/08/quickstart.html URL: http://svn.apache.org/viewvc/kafka/site/08/quickstart.html?rev=1485260r1=1485259r2

git commit: kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched by Jun Rao; reviewed by Neha Narkhede

2013-05-29 Thread junrao
Updated Branches: refs/heads/0.8 85c715915 - 312ed2e67 kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-649; Cleanup log4j logging (extra); patched by Jun Rao; reviewed by Neha Narkhede

2013-05-29 Thread junrao
Updated Branches: refs/heads/0.8 312ed2e67 - e4f287db6 kafka-649; Cleanup log4j logging (extra); patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e4f287db Tree:

git commit: kafka-259; Give better error message when trying to run shell scripts without having built/downloaded the jars yet; patched by Ashwanth Fernando; reviewed by Jun Rao

2013-05-29 Thread junrao
Updated Branches: refs/heads/0.8 bbb161aa2 - 436dd25a4 kafka-259; Give better error message when trying to run shell scripts without having built/downloaded the jars yet; patched by Ashwanth Fernando; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-891; NullPointerException in ConsoleConsumer; patched by Colin B.; reviewed by Neha Narkhede and Jun Rao

2013-05-29 Thread junrao
Updated Branches: refs/heads/trunk 731ba9007 - 3b470f56b kafka-891; NullPointerException in ConsoleConsumer; patched by Colin B.; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: trivial change to fix incorrect comment in Message

2013-05-29 Thread junrao
Updated Branches: refs/heads/0.8 436dd25a4 - 492ed7a35 trivial change to fix incorrect comment in Message Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/492ed7a3 Tree:

git commit: kafka-856; Correlation id for OffsetFetch request (#2) always responds with 0; patched by Milosz Tanski; reviewed by Jun Rao

2013-05-29 Thread junrao
Updated Branches: refs/heads/0.8 492ed7a35 - dc0de2925 kafka-856; Correlation id for OffsetFetch request (#2) always responds with 0; patched by Milosz Tanski; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-920; zkclient jar 0.2.0 is not compatible with 0.1.0; patched by Jun Rao; reviewed by Neha Narkhede

2013-05-30 Thread junrao
Updated Branches: refs/heads/0.8 dc0de2925 - d93cbc610 kafka-920; zkclient jar 0.2.0 is not compatible with 0.1.0; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d93cbc61

git commit: kafka-899; LeaderNotAvailableException the first time a new message for a partition is processed; patched by Jun Rao; reviewed by Neha Narkhede

2013-05-30 Thread junrao
Updated Branches: refs/heads/0.8 d93cbc610 - 1caae2c2a kafka-899; LeaderNotAvailableException the first time a new message for a partition is processed; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-927; Integrate controlled shutdown into kafka shutdown hook; patched by Sriram Subramanian; reviewed by Neha Narkhede and Jun Rao

2013-06-03 Thread junrao
Updated Branches: refs/heads/0.8 658427638 - 4f387ae43 kafka-927; Integrate controlled shutdown into kafka shutdown hook; patched by Sriram Subramanian; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

git commit: kafka-903; Attempt to swap the new high watermark file with the old one failed on Windows; patched by Jun Rao; reviewed by Neha Narkhede, Jay Kreps and Sriram Subramania

2013-06-03 Thread junrao
Updated Branches: refs/heads/0.8 4f387ae43 - 43c43b1c6 kafka-903; Attempt to swap the new high watermark file with the old one failed on Windows; patched by Jun Rao; reviewed by Neha Narkhede, Jay Kreps and Sriram Subramania Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

git commit: kafka-931; make zookeeper.connect a required property; patched by Jun Rao; reviewed by Neha Narkhede

2013-06-03 Thread junrao
Updated Branches: refs/heads/0.8 fb37ea8c7 - 9bd2a1148 kafka-931; make zookeeper.connect a required property; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9bd2a114 Tree:

svn commit: r1489289 - in /kafka/site: 07/quickstart.html 08/configuration.html

2013-06-03 Thread junrao
Author: junrao Date: Tue Jun 4 05:01:26 2013 New Revision: 1489289 URL: http://svn.apache.org/r1489289 Log: fix 0.7 download link and 0.8 configs Modified: kafka/site/07/quickstart.html kafka/site/08/configuration.html Modified: kafka/site/07/quickstart.html URL: http://svn.apache.org

svn commit: r1489499 - /kafka/site/08/configuration.html

2013-06-04 Thread junrao
Author: junrao Date: Tue Jun 4 16:18:44 2013 New Revision: 1489499 URL: http://svn.apache.org/r1489499 Log: fix default value of auto.offset.reset in 0.8 configs Modified: kafka/site/08/configuration.html Modified: kafka/site/08/configuration.html URL: http://svn.apache.org/viewvc/kafka

svn commit: r1489500 - /kafka/site/08/configuration.html

2013-06-04 Thread junrao
Author: junrao Date: Tue Jun 4 16:22:56 2013 New Revision: 1489500 URL: http://svn.apache.org/r1489500 Log: add missing ) in 0.8 configs Modified: kafka/site/08/configuration.html Modified: kafka/site/08/configuration.html URL: http://svn.apache.org/viewvc/kafka/site/08/configuration.html

git commit: trival change to review unneeded error logging since an exception is already thrown to the caller

2013-06-09 Thread junrao
Updated Branches: refs/heads/0.8 9b30aceea - ddb7947c0 trival change to review unneeded error logging since an exception is already thrown to the caller Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ddb7947c Tree:

git commit: kafka-938; High CPU usage when more or less idle; patched by Sam Meder; reviewed by Jun Rao

2013-06-11 Thread junrao
Updated Branches: refs/heads/0.8 ddb7947c0 - 6881bf08f kafka-938; High CPU usage when more or less idle; patched by Sam Meder; 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/6881bf08 Tree:

git commit: kafka-940; Scala match error in javaapi.Implicits; patched by Joel Koshy; reviewed by Jun Rao

2013-06-12 Thread junrao
Updated Branches: refs/heads/0.8 6881bf08f - 640026467 kafka-940; Scala match error in javaapi.Implicits; patched by Joel Koshy; 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/64002646 Tree:

git commit: kafka-937; ConsumerFetcherThread can deadlock; patched by Jun Rao; reviewed by Joel Koshy

2013-06-12 Thread junrao
Updated Branches: refs/heads/0.8 640026467 - 5bd33c151 kafka-937; ConsumerFetcherThread can deadlock; patched by Jun Rao; reviewed by Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5bd33c15 Tree:

git commit: trival change to increase default producer request timeout

2013-06-17 Thread junrao
Updated Branches: refs/heads/0.8 23acbd309 - 7ad742d80 trival change to increase default producer request timeout Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7ad742d8 Tree:

git commit: kafka-947; isr-expiration-thread may block LeaderAndIsr request for a relatively long period; patched by Jun Rao; reviewed by Joel Koshy

2013-06-20 Thread junrao
Updated Branches: refs/heads/0.8 7b43f0132 - cc6027b32 kafka-947; isr-expiration-thread may block LeaderAndIsr request for a relatively long period; patched by Jun Rao; reviewed by Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

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

2013-06-27 Thread junrao
Author: junrao Date: Thu Jun 27 16:50:29 2013 New Revision: 1497439 URL: http://svn.apache.org/r1497439 Log: add 0.8.0 beta1 download links Modified: kafka/site/downloads.html Modified: kafka/site/downloads.html URL: http://svn.apache.org/viewvc/kafka/site/downloads.html?rev=1497439r1

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

2013-07-05 Thread junrao
Author: junrao Date: Fri Jul 5 22:59:41 2013 New Revision: 1500159 URL: http://svn.apache.org/r1500159 Log: fix 0.7.2 download links Modified: kafka/site/downloads.html Modified: kafka/site/downloads.html URL: http://svn.apache.org/viewvc/kafka/site/downloads.html?rev=1500159r1=1500158r2

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

2013-07-05 Thread junrao
Author: junrao Date: Fri Jul 5 23:02:04 2013 New Revision: 1500161 URL: http://svn.apache.org/r1500161 Log: minor change to remove extra ) in download page Modified: kafka/site/downloads.html Modified: kafka/site/downloads.html URL: http://svn.apache.org/viewvc/kafka/site/downloads.html

[09/43] git commit: KAFKA-829 Mirror maker needs to share the migration tool request channel; reviewed by Jun Rao

2013-07-08 Thread junrao
KAFKA-829 Mirror maker needs to share the migration tool request channel; 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/66b10389 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/66b10389 Diff:

[27/43] git commit: KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps

2013-07-08 Thread junrao
KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f9e36ca7 Tree:

[21/43] git commit: KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike

2013-07-08 Thread junrao
KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1d3c343f Tree:

[38/43] git commit: KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun

2013-07-08 Thread junrao
KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/103aef8c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/103aef8c

[18/43] git commit: kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede

2013-07-08 Thread junrao
kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5a50f7e5 Tree:

[01/43] git commit: kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao

2013-07-08 Thread junrao
Updated Branches: refs/heads/trunk 3b470f56b - 2cda5d1fc kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede 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/28ee7855

[15/43] git commit: KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede

2013-07-08 Thread junrao
KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a9ce73cf Tree:

[41/43] git commit: KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy

2013-07-08 Thread junrao
KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/988d4d8e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/988d4d8e Diff:

[03/43] git commit: kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede

2013-07-08 Thread junrao
kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e367f3ff Tree:

  1   2   3   4   5   6   7   8   9   10   >