This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 37493d1 KAFKA-10847: Add new RocksDBTimeOrderedWindowStore that
persists (time-key)-value records (#10331)
add 00ec646 KAFKA-7785: move internal DefaultPartitionGrouper (#10302)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 17 -------
.../kafka/streams/processor/PartitionGrouper.java | 55 ----------------------
.../PartitionGrouper.java} | 12 ++---
.../internals/StreamsPartitionAssignor.java | 4 +-
.../assignment/AssignorConfiguration.java | 8 ----
.../apache/kafka/streams/StreamsConfigTest.java | 20 --------
.../PartitionGrouperTest.java} | 12 ++---
.../internals/SingleGroupPartitionGrouperStub.java | 45 ------------------
.../internals/StreamsPartitionAssignorTest.java | 35 --------------
9 files changed, 13 insertions(+), 195 deletions(-)
delete mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java
rename
streams/src/main/java/org/apache/kafka/streams/processor/{DefaultPartitionGrouper.java
=> internals/PartitionGrouper.java} (90%)
rename
streams/src/test/java/org/apache/kafka/streams/processor/{DefaultPartitionGrouperTest.java
=> internals/PartitionGrouperTest.java} (92%)
delete mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/SingleGroupPartitionGrouperStub.java
