[2/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores

http://git-wip-us.apache.org/repos/asf/kafka/blob/ec9e4eaf/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java -- diff --git

[4/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores

http://git-wip-us.apache.org/repos/asf/kafka/blob/ec9e4eaf/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java -- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java

[5/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores

KAFKA-5045: Clarify on KTable APIs for queryable stores This is the implementation of KIP-114: KTable state stores and improved semantics: - Allow for decoupling between querying and materialisation - consistent APIs, overloads with queryableName and without - depreciated several KTable calls -

[3/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores

http://git-wip-us.apache.org/repos/asf/kafka/blob/ec9e4eaf/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java -- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java

[1/5] kafka git commit: KAFKA-5045: Clarify on KTable APIs for queryable stores

Repository: kafka Updated Branches: refs/heads/trunk a3952aee4 -> ec9e4eafa http://git-wip-us.apache.org/repos/asf/kafka/blob/ec9e4eaf/streams/src/test/java/org/apache/kafka/streams/kstream/KStreamBuilderTest.java -- diff

kafka git commit: KAFKA-5055: Fix Kafka Streams skipped-records-rate sensor bug

Repository: kafka Updated Branches: refs/heads/trunk bc65c62e6 -> a3952aee4 KAFKA-5055: Fix Kafka Streams skipped-records-rate sensor bug Fix as described in the [KAFKA-5055 Jira

kafka git commit: KAFKA-5144: renamed variables in MinTimestampTracker and added comments

Repository: kafka Updated Branches: refs/heads/trunk cfb238674 -> bc65c62e6 KAFKA-5144: renamed variables in MinTimestampTracker and added comments The descendingSubsequence is a misnomer. The linked list is actually arranged so that the lowest timestamp is first and larger timestamps are

kafka git commit: MINOR: Fix error logged if not enough alive brokers for transactions state topic

Repository: kafka Updated Branches: refs/heads/trunk a7671c7f3 -> cfb238674 MINOR: Fix error logged if not enough alive brokers for transactions state topic Author: Ismael Juma Reviewers: Guozhang Wang Closes #2954 from

kafka git commit: KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts

Repository: kafka Updated Branches: refs/heads/trunk 8d7492016 -> a7671c7f3 KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts Tests broker with multiple SASL mechanisms with different endpoints for different mechanisms. Each endpoint uses its own JAAS context.

kafka git commit: KAFKA-3754; Add GC log retention policy to limit size of log

Repository: kafka Updated Branches: refs/heads/trunk 4a6bbd5f1 -> 8d7492016 KAFKA-3754; Add GC log retention policy to limit size of log Add a default log retention policy to keep GC logs from growing too large Author: Ryan P Reviewers: Ismael Juma

kafka git commit: KAFA-4378: Fix Scala 2.12 "eta-expansion of zero-argument method" warnings

Repository: kafka Updated Branches: refs/heads/trunk f60009b14 -> 4a6bbd5f1 KAFA-4378: Fix Scala 2.12 "eta-expansion of zero-argument method" warnings Author: Bernard Leach Reviewers: Ismael Juma Closes #2098 from leachbj/4378-eta-expansion