kafka git commit: KAFKA-5704: Corrected Connect distributed startup behavior to allow older brokers to auto-create topics

2017-08-08 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 d0be27b4e -> 3bc5ee7dd KAFKA-5704: Corrected Connect distributed startup behavior to allow older brokers to auto-create topics When a Connect distributed worker starts up talking with broker versions 0.10.1.0 and later, it will use the

kafka git commit: KAFKA-5704: Corrected Connect distributed startup behavior to allow older brokers to auto-create topics

2017-08-08 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk b8cf97686 -> 1a653c813 KAFKA-5704: Corrected Connect distributed startup behavior to allow older brokers to auto-create topics When a Connect distributed worker starts up talking with broker versions 0.10.1.0 and later, it will use the

kafka git commit: MINOR: support retrieving cluster_id in system tests

2017-08-08 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 0bf34e715 -> d0be27b4e MINOR: support retrieving cluster_id in system tests ewencp would be great to cherry-pick this back into 0.11.x if possible Author: Xavier Léauté Reviewers: Ewen Cheslack-Postava

kafka git commit: MINOR: support retrieving cluster_id in system tests

2017-08-08 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk fb8edbdc6 -> b8cf97686 MINOR: support retrieving cluster_id in system tests ewencp would be great to cherry-pick this back into 0.11.x if possible Author: Xavier Léauté Reviewers: Ewen Cheslack-Postava

kafka git commit: MINOR: Update dependencies for 1.0.0 release

2017-08-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 649276abb -> fb8edbdc6 MINOR: Update dependencies for 1.0.0 release Notable updates: 1. Gradle 4.1 includes a number of performance and CLI improvements as well as initial Java 9 support. 2. Scala 2.12.3 has substantial compilation time

kafka git commit: KAFKA-2360; Extract producer-specific configs out of the common PerfConfig

2017-08-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 98d4a4833 -> 649276abb KAFKA-2360; Extract producer-specific configs out of the common PerfConfig Separate `batch.size`, `message-size` and `compression-code` from PerfConfig to a newly-created ProducerPerfConfig in order to hide them in

kafka git commit: MINOR: Remove unused GroupState.state field

2017-08-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk c9ffab162 -> 98d4a4833 MINOR: Remove unused GroupState.state field This field doesn't seem to be used and the value for `AwaitingSync` seems to be wrong (it seems like it should have been `2` instead of `5`). Author: Ismael Juma

kafka git commit: KAFKA-5658; Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions

2017-08-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 57770dd23 -> c9ffab162 KAFKA-5658; Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions The AdminClient does not properly clear calls from the callsInFlight structure. Later, in an effort to

kafka git commit: KAFKA-5658; Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions

2017-08-08 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 557001f9f -> 0bf34e715 KAFKA-5658; Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions The AdminClient does not properly clear calls from the callsInFlight structure. Later, in an effort to