kafka git commit: MINOR: Include response in request log

2017-09-07 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 07a428e0c -> 27336192f MINOR: Include response in request log It's implemented such that there is no overhead if request logging is disabled. Also: - Reduce metrics computation duplication in `updateRequestMetrics` - Change a couple of log

kafka git commit: MINOR: Always specify the keystore type in system tests

2017-09-07 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk a1ec6527d -> 07a428e0c MINOR: Always specify the keystore type in system tests Also throw an exception if a null keystore type is seen in `SecurityStore`. This should never happen. The default keystore type has changed in Java 9 (

kafka git commit: KAFKA-5820: Remove unneeded synchronized keyword in StreamThread

2017-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 674407908 -> a1ec6527d KAFKA-5820: Remove unneeded synchronized keyword in StreamThread I removed synchronized keyword from 3 methods. I ran the change thru streams module where test suite passed. Author: tedyu

kafka git commit: KAFKA-5698: Sort processor nodes based on its sub-tree size

2017-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 3410f02fe -> 674407908 KAFKA-5698: Sort processor nodes based on its sub-tree size 1. Sort processor nodes within a sub-topology by its sub-tree size: nodes with largest sizes are source nodes and hence printed earlier. 2. Sort

kafka git commit: KAFKA-4585: Lower the Minimum Required ACL Permission of OffsetFetch (KIP-163)

2017-09-07 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 4065ffb3e -> 3410f02fe KAFKA-4585: Lower the Minimum Required ACL Permission of OffsetFetch (KIP-163) Details can be found in the

kafka git commit: KAFKA-5777; Add ducktape integration for Trogdor

2017-09-07 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 329d5fa64 -> 4065ffb3e KAFKA-5777; Add ducktape integration for Trogdor Author: Colin P. Mccabe Reviewers: Rajini Sivaram Closes #3726 from cmccabe/KAFKA-5777 Project:

kafka git commit: KAFKA-5844; add groupBy(selector, serialized) to Ktable

2017-09-07 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 9cbb9f093 -> 329d5fa64 KAFKA-5844; add groupBy(selector, serialized) to Ktable add `KTable#groupBy(KeyValueMapper, Serialized)` and deprecate the overload with `Serde` params Author: Damian Guy Reviewers: Matthias

[1/2] kafka git commit: KAFKA-5650; add StateStoreBuilder interface and implementations

2017-09-07 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 667cd60dc -> 9cbb9f093 http://git-wip-us.apache.org/repos/asf/kafka/blob/9cbb9f09/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java