[2/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

http://git-wip-us.apache.org/repos/asf/kafka/blob/9170e87b/streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java -- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java

[3/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

KAFKA-5192: add WindowStore range scan (KIP-155) Implements range scan for keys in windowed and session stores Modifies caching session and windowed stores to use segmented cache keys. Cache keys are internally prefixed with their segment id to ensure key ordering in the cache matches the

[1/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

Repository: kafka Updated Branches: refs/heads/0.11.0 b661d3b8a -> 9170e87b2 http://git-wip-us.apache.org/repos/asf/kafka/blob/9170e87b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java

[3/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

KAFKA-5192: add WindowStore range scan (KIP-155) Implements range scan for keys in windowed and session stores Modifies caching session and windowed stores to use segmented cache keys. Cache keys are internally prefixed with their segment id to ensure key ordering in the cache matches the

[1/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

Repository: kafka Updated Branches: refs/heads/trunk b661d3b8a -> e28752357 http://git-wip-us.apache.org/repos/asf/kafka/blob/e2875235/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java

[2/3] kafka git commit: KAFKA-5192: add WindowStore range scan (KIP-155)

http://git-wip-us.apache.org/repos/asf/kafka/blob/e2875235/streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java -- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java

[kafka] Git Push Summary

Repository: kafka Updated Branches: refs/heads/0.11.0 [created] b661d3b8a

kafka git commit: MINOR: Small refactor of request quotas handling in KafkaApis

Repository: kafka Updated Branches: refs/heads/trunk 56623efd7 -> b661d3b8a MINOR: Small refactor of request quotas handling in KafkaApis - Avoid unnecessary inner methods - Remove redundant parameter in `sendResponseExemptThrottle` - Go through `sendResponseExemptThrottle` for produce

kafka git commit: KAFKA-4667: Connect uses AdminClient to create internal topics when needed (KIP-154)

Repository: kafka Updated Branches: refs/heads/trunk 30736da65 -> 56623efd7 KAFKA-4667: Connect uses AdminClient to create internal topics when needed (KIP-154) The backing store for offsets, status, and configs now attempts to use the new AdminClient to look up the internal topics and

kafka git commit: HOTFIX: Close transactional producers in all new tests

Repository: kafka Updated Branches: refs/heads/trunk 96959bc56 -> 30736da65 HOTFIX: Close transactional producers in all new tests Author: Apurva Mehta Reviewers: Jason Gustafson Closes #3093 from

kafka git commit: KAFKA-5250: Do fetch down conversion after throttling

Repository: kafka Updated Branches: refs/heads/trunk 65edd64ca -> 96959bc56 KAFKA-5250: Do fetch down conversion after throttling Perform down conversion after throttling to avoid retaining messages in memory during throttling since this could result in OOM. Also update bytesOut metrics after

kafka git commit: KAFKA-3070: SASL unit tests dont work with IBM JDK

Repository: kafka Updated Branches: refs/heads/trunk c1fdf575d -> 65edd64ca KAFKA-3070: SASL unit tests dont work with IBM JDK Use IBM Kerberos module for SASL tests if running on IBM JDK Developed with edoardocomar Based on https://github.com/apache/kafka/pull/738 by rajinisivaram Author:

kafka git commit: KAFKA-5033; Set default retries for the idempotent producer to be infinite

Repository: kafka Updated Branches: refs/heads/trunk 34e379f10 -> c1fdf575d KAFKA-5033; Set default retries for the idempotent producer to be infinite Author: Apurva Mehta Reviewers: Jason Gustafson Closes #3091 from

kafka git commit: KAFKA-5171; TC should not accept empty string transactional id

Repository: kafka Updated Branches: refs/heads/trunk d662b09c9 -> 34e379f10 KAFKA-5171; TC should not accept empty string transactional id This is a rebase version of [PR#2973](https://github.com/apache/kafka/pull/2973). guozhangwang , please review this updated PR. Author: umesh chaudhary

kafka git commit: KAFKA-5268; Fix bounce test transient failure by clearing partitions before writing Complete state to transaction log

Repository: kafka Updated Branches: refs/heads/trunk 45f226176 -> d662b09c9 KAFKA-5268; Fix bounce test transient failure by clearing partitions before writing Complete state to transaction log Author: Jason Gustafson Reviewers: Guozhang Wang

[2/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146)

http://git-wip-us.apache.org/repos/asf/kafka/blob/45f22617/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java -- diff --git

[3/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146)

KAFKA-3487: Support classloading isolation in Connect (KIP-146) Author: Konstantine Karantasis Reviewers: Randall Hauch , Ewen Cheslack-Postava Closes #3028 from kkonstantine/KAFKA-3487-Support-classloading-isolation-in-Connect

[1/3] kafka git commit: KAFKA-3487: Support classloading isolation in Connect (KIP-146)

Repository: kafka Updated Branches: refs/heads/trunk 5aaaba7ff -> 45f226176 http://git-wip-us.apache.org/repos/asf/kafka/blob/45f22617/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java

kafka git commit: KAFKA-5258; Move all partition and replica state transition rules into their states

Repository: kafka Updated Branches: refs/heads/trunk 816578b5c -> 5aaaba7ff KAFKA-5258; Move all partition and replica state transition rules into their states Today PartitionStateMachine and ReplicaStateMachine define and assert the valid state transitions inline for each state. It's

kafka git commit: KAFKA-4222; QueryableIntegrationTest.queryOnRebalance transient failure

Repository: kafka Updated Branches: refs/heads/trunk 14a3d69d9 -> 816578b5c KAFKA-4222; QueryableIntegrationTest.queryOnRebalance transient failure Don't produce messages on a separate thread continuosly. Just produce one of each value and stop. Close the producer once finished. Author:

kafka git commit: TRIVIAL: Remove redundant asMap utility in ConsumerProtocol

Repository: kafka Updated Branches: refs/heads/trunk 9fa0d52ca -> 14a3d69d9 TRIVIAL: Remove redundant asMap utility in ConsumerProtocol Author: Jason Gustafson Reviewers: Ismael Juma Closes #3084 from hachikuji/trivial-remove-redundant-utility

kafka git commit: KAFKA-5210: Application Reset Tool does not need to seek for internal topics

Repository: kafka Updated Branches: refs/heads/trunk 972b75453 -> 9fa0d52ca KAFKA-5210: Application Reset Tool does not need to seek for internal topics mjsax dguy guozhangwang Could you please review the changes. Author: Bharat Viswanadham Reviewers: Matthias J. Sax,