[1/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133)

Repository: kafka Updated Branches: refs/heads/trunk e1abf1770 -> 972b75453 http://git-wip-us.apache.org/repos/asf/kafka/blob/972b7545/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala -- diff --git

[2/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133)

http://git-wip-us.apache.org/repos/asf/kafka/blob/972b7545/clients/src/main/java/org/apache/kafka/common/requests/ApiError.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ApiError.java

[3/3] kafka git commit: KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133)

KAFKA-3267; Describe and Alter Configs Admin APIs (KIP-133) Author: Ismael Juma Reviewers: Jun Rao Closes #3076 from ijuma/kafka-3267-describe-alter-configs-protocol Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/2] kafka git commit: KAFKA-2273; Sticky partition assignment strategy (KIP-54)

KAFKA-2273; Sticky partition assignment strategy (KIP-54) This PR implements a new partition assignment strategy called "sticky", and it's purpose is to balance partitions across consumers in a way that minimizes moving partitions around, or, in other words, preserves existing partition

[2/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140)

http://git-wip-us.apache.org/repos/asf/kafka/blob/9815e18f/clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java -- diff --git

[1/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140)

Repository: kafka Updated Branches: refs/heads/trunk 249152062 -> 9815e18fe http://git-wip-us.apache.org/repos/asf/kafka/blob/9815e18f/core/src/main/scala/kafka/server/KafkaApis.scala -- diff --git

[3/3] kafka git commit: KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140)

KAFKA-3266; Describe, Create and Delete ACLs Admin APIs (KIP-140) Includes server-side code, protocol and AdminClient. Author: Colin P. Mccabe Reviewers: Ismael Juma Closes #2941 from cmccabe/KAFKA-3266 Project:

kafka git commit: KAFKA-5036; hold onto the leader lock in Partition while serving an O…

Repository: kafka Updated Branches: refs/heads/trunk c64cfd2e2 -> 249152062 KAFKA-5036; hold onto the leader lock in Partition while serving an O… …ffsetForLeaderEpoch request Author: Jun Rao Reviewers: Ismael Juma , Ben Stopford

kafka git commit: KAFKA-5231: Bump up producer epoch when sending abort txn markers on InitPid

Repository: kafka Updated Branches: refs/heads/trunk b3a33ce4b -> c64cfd2e2 KAFKA-5231: Bump up producer epoch when sending abort txn markers on InitPid Author: Guozhang Wang Reviewers: Jason Gustafson, Jun Rao Closes #3066 from

kafka git commit: KAFKA-4772: Exploit #peek to implement #print() and other methods

Repository: kafka Updated Branches: refs/heads/trunk 8c7e66313 -> 6910baf54 KAFKA-4772: Exploit #peek to implement #print() and other methods I remove `KeyValuePrinter` and `KStreamForeach` two class, then implements them by `KStreamPeek`. So, now `KStreamPeek` can do `KeyValuePrinter` and

kafka git commit: KAFKA-5182: Reduce rebalance timeouts in request quota test

Repository: kafka Updated Branches: refs/heads/trunk c36b5b7f6 -> 8c7e66313 KAFKA-5182: Reduce rebalance timeouts in request quota test Reduce rebalance and session timeouts for join requests to trigger throttling in the request quota test. Author: Rajini Sivaram

kafka git commit: MINOR: Make some constructors in admin package public

Repository: kafka Updated Branches: refs/heads/trunk 62d5aac5d -> c36b5b7f6 MINOR: Make some constructors in admin package public Add a public create API that takes a Properties instance. Make the constructors for TopicDescription, TopicListing and TopicPartitionInfo public to enable

kafka git commit: MINOR: Use new-consumer config in MirrorMaker doc

Repository: kafka Updated Branches: refs/heads/trunk 1cea4d8f5 -> 62d5aac5d MINOR: Use new-consumer config in MirrorMaker doc Mirrormaker was updated to default to the new consumer in 3db752a565071c78e4b11eaafa739844fa785b04 Old consumer calls the param `auto.commit.enable`, new consumer

kafka git commit: KAFKA-4714; Flatten and Cast single message transforms (KIP-66)

Repository: kafka Updated Branches: refs/heads/trunk ebc7f7caa -> 1cea4d8f5 KAFKA-4714; Flatten and Cast single message transforms (KIP-66) Author: Ewen Cheslack-Postava Reviewers: Konstantine Karantasis , Shikhar Bhushan ,