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
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 (
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
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
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
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:
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
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