[1/2] kafka git commit: KAFKA-5856; Add AdminClient.createPartitions() (KIP-195)

2017-09-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 94692288b -> 5f6393f9b http://git-wip-us.apache.org/repos/asf/kafka/blob/5f6393f9/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala -- diff --git

[2/2] kafka git commit: KAFKA-5856; Add AdminClient.createPartitions() (KIP-195)

2017-09-20 Thread ijuma
KAFKA-5856; Add AdminClient.createPartitions() (KIP-195) The contribution is my original work and I license the work to the project under the project's open source license. This patch adds AdminClient.createPartitions() and the network protocol is uses. The broker-side algorithm is as follows:

kafka git commit: KAFKA-5793; Tighten up the semantics of the OutOfOrderSequenceException

2017-09-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 69d2a1771 -> 94692288b KAFKA-5793; Tighten up the semantics of the OutOfOrderSequenceException Description of the solution can be found here:

kafka git commit: KAFKA-5854; Handle SASL authentication failures as non-retriable exceptions in clients

2017-09-20 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk c2af13ed0 -> 69d2a1771 KAFKA-5854; Handle SASL authentication failures as non-retriable exceptions in clients This PR implements the client-side of KIP-152, by modifying `KafkaConsumer`, `KafkaProducer`, and `ConsumerGroupCommand` to

kafka git commit: MINOR: Upgrade to Gradle 4.2

2017-09-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 552b17078 -> c2af13ed0 MINOR: Upgrade to Gradle 4.2 It includes the usual performance improvements, but the nicest improvement for me is that the findBugs plugin no longer outputs 1+ lines in Jenkins builds:

kafka git commit: KAFKA-5657: Connect REST API should include the connector type when describing a connector (KIP-151)

2017-09-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 239dad1b9 -> 552b17078 KAFKA-5657: Connect REST API should include the connector type when describing a connector (KIP-151) Embed the type of connector in ConnectorInfo Author: tedyu Reviewers: Randall Hauch

kafka git commit: KAFKA-5358; Consumer perf tool should count rebalance time (KIP-177)

2017-09-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk c82be0f30 -> 239dad1b9 KAFKA-5358; Consumer perf tool should count rebalance time (KIP-177) Author: huxihx Reviewers: Jason Gustafson Closes #3188 from huxihx/KAKFA-5358 Project:

kafka-site git commit: Deploy latest 0110 docs from Kafka commit f16fc68e

2017-09-20 Thread ewencp
Repository: kafka-site Updated Branches: refs/heads/asf-site 19d643354 -> a872ac8a1 Deploy latest 0110 docs from Kafka commit f16fc68e Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/a872ac8a Tree:

kafka git commit: MINOR: Adding See how Kafka Streams is being used section to Streams page

2017-09-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 1df108421 -> f16fc68ec MINOR: Adding See how Kafka Streams is being used section to Streams page Author: manjuapu Author: Manjula K Reviewers: Ewen Cheslack-Postava

kafka git commit: MINOR: Adding See how Kafka Streams is being used section to Streams page

2017-09-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk bb9859720 -> c82be0f30 MINOR: Adding See how Kafka Streams is being used section to Streams page Author: manjuapu Author: Manjula K Reviewers: Ewen Cheslack-Postava

kafka git commit: MINOR: change task initialization logging levels

2017-09-20 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 37ec15e96 -> bb9859720 MINOR: change task initialization logging levels In `AssignedTasks` log at debug all task ids that are yet to be initialized. In `StreamsTask` log at trace when the task is initialized. Author: Damian Guy

kafka git commit: KAFKA-5931; deprecate KTable#through and KTable#to

2017-09-20 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk c58790595 -> 37ec15e96 KAFKA-5931; deprecate KTable#through and KTable#to Author: Damian Guy Reviewers: Matthias J. Sax , Bill Bejeck , Guozhang Wang

kafka git commit: MINOR: update release script for streams quickstart

2017-09-20 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 398714b75 -> c58790595 MINOR: update release script for streams quickstart Author: Damian Guy Reviewers: Ismael Juma , Guozhang Wang Closes #3846 from

kafka git commit: KAFKA-5839: Upgrade Guide doc changes for KIP-130

2017-09-20 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk bd0146d98 -> 398714b75 KAFKA-5839: Upgrade Guide doc changes for KIP-130 Author: Florian Hussonnois Reviewers: Matthias J. Sax , Guozhang Wang Closes #3811 from