kafka git commit: KAFKA-2626: Handle null keys and value validation properly in OffsetStorageWriter.

2015-10-23 Thread gwenshap
Repository: kafka Updated Branches: refs/heads/trunk 2e6177359 -> 6f2f1f984 KAFKA-2626: Handle null keys and value validation properly in OffsetStorageWriter. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #345 from

[3/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

2015-10-23 Thread gwenshap
KAFKA-2371: Add distributed support for Copycat. This adds coordination between DistributedHerders using the generalized consumer support, allowing automatic balancing of connectors and tasks across workers. A few pieces that require interaction between workers (resolving config inconsistencies,

[1/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

2015-10-23 Thread gwenshap
Repository: kafka Updated Branches: refs/heads/trunk 21443f214 -> 2e6177359 http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderTest.java

[2/3] kafka git commit: KAFKA-2371: Add distributed support for Copycat.

2015-10-23 Thread gwenshap
http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderConfig.java -- diff --git

kafka git commit: KAFKA-2641; Upgrade path for ZK authentication

2015-10-23 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 701c46b3a -> 21443f214 KAFKA-2641; Upgrade path for ZK authentication This pull request adds a configuration parameter and a migration tool. It is also based on pull request #303, which should go in first. Author: flavio junqueira