kafka git commit: KAFKA-6003; Accept appends on replicas unconditionally when local producer state doesn't exist

2017-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk b5b266eee -> 6ea4fffdd KAFKA-6003; Accept appends on replicas unconditionally when local producer state doesn't exist Without this patch, if the replica's log was somehow truncated before the leader's, it is possible for the replica

[kafka] Git Push Summary

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0 [created] 5792f2fb3

[kafka] Git Push Summary

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0.0 [deleted] 5dab884d7

kafka git commit: KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-10-04 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 20d9adb17 -> b5b266eee KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event Author: Dong Lin Reviewers: Ismael Juma , Jun Rao

kafka git commit: KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-10-04 Thread junrao
Repository: kafka Updated Branches: refs/heads/1.0.0 0222a35db -> 5dab884d7 KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event Author: Dong Lin Reviewers: Ismael Juma , Jun Rao

[kafka-site] Git Push Summary [forced push!] [Forced Update!]

2017-10-04 Thread guozhang
Repository: kafka-site Updated Branches: refs/heads/asf-site 72b3bc737 -> 851b2683e (forced update)

kafka git commit: KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory failure

2017-10-04 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 6bcbd17d3 -> 20d9adb17 KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory failure Author: Dong Lin Reviewers: Ismael Juma , Jun Rao Closes #3718 from

kafka git commit: KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory failure

2017-10-04 Thread junrao
Repository: kafka Updated Branches: refs/heads/1.0.0 5792f2fb3 -> 0222a35db KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory failure Author: Dong Lin Reviewers: Ismael Juma , Jun Rao Closes #3718 from

kafka git commit: Bump up version to 1.1.0-SNAPSHOT

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 5792f2fb3 -> 6bcbd17d3 Bump up version to 1.1.0-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6bcbd17d Tree:

[kafka] Git Push Summary

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0.0 [created] 5792f2fb3

kafka git commit: KAFKA-5980: FailOnInvalidTimestamp does not log error

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 713a67fdd -> 5792f2fb3 KAFKA-5980: FailOnInvalidTimestamp does not log error Author: Matthias J. Sax Reviewers: Damian Guy , Ted Yu , Denis Bolshakov Closes #3966 from

[1/2] kafka git commit: MINOR: add suppress warnings annotations in Streams API

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 51c652c40 -> 713a67fdd http://git-wip-us.apache.org/repos/asf/kafka/blob/713a67fd/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java -- diff

[2/2] kafka git commit: MINOR: add suppress warnings annotations in Streams API

2017-10-04 Thread guozhang
MINOR: add suppress warnings annotations in Streams API - fixes examples with regard to new API - fixes `Topology#addGlobalStore` parameters Author: Matthias J. Sax Reviewers: Ismael Juma , Guozhang Wang , Damian Guy

kafka git commit: KAFKA-6010; Relax record conversion time test to avoid build failure

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 06738b41b -> 51c652c40 KAFKA-6010; Relax record conversion time test to avoid build failure For record conversion tests, check time >=0 since conversion times may be too small to be measured accurately. Since default value is -1, the test

kafka git commit: MINOR: JavaDoc improvements for new state store API

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 93b71e7de -> 06738b41b MINOR: JavaDoc improvements for new state store API Author: Matthias J. Sax Reviewers: Michael G. Noll , Bill Bejeck , Guozhang Wang

kafka git commit: MINOR: update streams quickstart for KIP-182

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk ac7695c32 -> 93b71e7de MINOR: update streams quickstart for KIP-182 Author: Damian Guy Reviewers: Michael G. Noll , Bill Bejeck , Matthias J. Sax ,

kafka git commit: KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking

2017-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 51ea8e76b -> ab554caee KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking Author: Rajini Sivaram Reviewers: Guozhang Wang , Ismael Juma , Jason

kafka git commit: KAFKA-6008: Sanitize the app id before creating app id metric

2017-10-04 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk f8621b417 -> ac7695c32 KAFKA-6008: Sanitize the app id before creating app id metric Author: Jakub Scholz Reviewers: Randall Hauch , Ewen Cheslack-Postava Closes #4012 from

kafka git commit: KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking

2017-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk d985513b2 -> f8621b417 KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking Author: Rajini Sivaram Reviewers: Guozhang Wang , Ismael Juma , Jason

kafka git commit: MINOR: streams dev guide fixup

2017-10-04 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 11afff099 -> d985513b2 MINOR: streams dev guide fixup Author: Joel Hamill Author: Joel Hamill <11722533+joel-ham...@users.noreply.github.com> Reviewers: Derrick Or , Michael G. Noll

kafka git commit: KAFKA-5990: Enable generation of metrics docs for Connect (KIP-196)

2017-10-04 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk c6e5a32d0 -> 11afff099 KAFKA-5990: Enable generation of metrics docs for Connect (KIP-196) A new mechanism was added recently to the Metrics framework to make it easier to generate the documentation. It uses a registry with a

kafka git commit: KAFKA-5856; AdminClient.createPartitions() follow up

2017-10-04 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 2a1b39ef1 -> c6e5a32d0 KAFKA-5856; AdminClient.createPartitions() follow up - Improve tests and javadoc (including expected exceptions) - Return correct authorization error if no describe topic permission Author: Tom Bentley

kafka git commit: MINOR: Simplify log cleaner and fix compiler warnings

2017-10-04 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 9949e1ed1 -> 2a1b39ef1 MINOR: Simplify log cleaner and fix compiler warnings - Simplify LogCleaner.cleanSegments and add comment regarding thread unsafe usage of `LogSegment.append`. This was a result of investigating KAFKA-4972. - Fix

kafka git commit: KAFKA-6004; Allow authentication providers to override error message

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 5afeddaa9 -> 9949e1ed1 KAFKA-6004; Allow authentication providers to override error message Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4015 from

kafka git commit: KAFKA-5967; Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

2017-10-04 Thread damianguy
Repository: kafka Updated Branches: refs/heads/0.11.0 fae2d2386 -> 51ea8e76b KAFKA-5967; Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() package name: org.apache.kafka.streams.state.internals Minor change to approximateNumEntries() method in

kafka git commit: KAFKA-5967; Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

2017-10-04 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 5383f9bed -> 5afeddaa9 KAFKA-5967; Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() package name: org.apache.kafka.streams.state.internals Minor change to approximateNumEntries() method in

[2/2] kafka git commit: MINOR: Use SecurityProtocol in AuthenticationContext

2017-10-04 Thread jgus
MINOR: Use SecurityProtocol in AuthenticationContext Since we removed the unused `TRACE` option from `SecurityProtocol`, it now seems safer to expose it from `AuthenticationContext`. Additionally this patch exposes javadocs under security.auth and relocates the `Login` and

[1/2] kafka git commit: MINOR: Use SecurityProtocol in AuthenticationContext

2017-10-04 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 198302fee -> 5383f9bed http://git-wip-us.apache.org/repos/asf/kafka/blob/5383f9be/core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala -- diff --git

kafka git commit: KAFKA-5738; Upgrade note for cumulative count metric (KIP-187)

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a202da742 -> c4b8a7eab KAFKA-5738; Upgrade note for cumulative count metric (KIP-187) Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4014 from rajinisivaram/MINOR-upgrade-KIP-187

kafka git commit: KAFKA-4764; Upgrade notes for authentication failure handling (KIP-152)

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 28aaba281 -> a202da742 KAFKA-4764; Upgrade notes for authentication failure handling (KIP-152) Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4013 from

kafka git commit: MINOR: Java 9 version handling improvements

2017-10-04 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk cbef33f3d -> 28aaba281 MINOR: Java 9 version handling improvements - Upgrade Gradle to 4.2.1, which handles Azul Zulu 9's version correctly. - Add tests to our Java version handling code - Refactor the code to make it possible to add tests