This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 420162d KAFKA-10251: increase timeout for consuming records (#10228)
add a848e0c KAFKA-10357: Extract setup of changelog from Streams
partition assignor (#10163)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ChangelogTopics.java | 132 +++++++++++++
.../internals/StreamsPartitionAssignor.java | 147 ++++-----------
.../processor/internals/ChangelogTopicsTest.java | 208 +++++++++++++++++++++
3 files changed, 373 insertions(+), 114 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogTopics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/ChangelogTopicsTest.java
