git commit: KAFKA-1257 Only send metadata requests to nodes with no in-flight requests.

2014-02-11 Thread jkreps
Updated Branches: refs/heads/trunk cdd03d199 -> e1845ba1d KAFKA-1257 Only send metadata requests to nodes with no in-flight requests. Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e1845ba1 Tree: http://git-wip-us.apache.

git commit: KAFKA-1259 Close blocked only until all messages had been sent not until all acknowledgements had been received.

2014-02-11 Thread jkreps
Updated Branches: refs/heads/trunk e1845ba1d -> ef1e30bf5 KAFKA-1259 Close blocked only until all messages had been sent not until all acknowledgements had been received. Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ef

git commit: KAFKA-1237 Follow up review suggestions on new mirror maker; reviewed by Guozhang Wang

2014-02-11 Thread nehanarkhede
Updated Branches: refs/heads/trunk d6303ec79 -> cdd03d199 KAFKA-1237 Follow up review suggestions on new mirror maker; reviewed by Guozhang Wang Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cdd03d19 Tree: http://git-wi

git commit: KAFKA-1233 Adding the new test file

2014-02-11 Thread nehanarkhede
Updated Branches: refs/heads/trunk a0939f412 -> d6303ec79 KAFKA-1233 Adding the new test file Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d6303ec7 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d6303ec7 Diff:

git commit: KAFKA-1233 Integration test for the new producer; reviewed by Jay Kreps and Neha Narkhede

2014-02-11 Thread nehanarkhede
Updated Branches: refs/heads/trunk 71e21c6ba -> a0939f412 KAFKA-1233 Integration test for the new producer; reviewed by Jay Kreps and Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a0939f41 Tree: http://git