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 5380938 MINOR: Add timer for update limit offsets (#8047)
add f698f3f MINOR: further InternalTopologyBuilder cleanup (#8046)
No new revisions were added by this update.
Summary of changes:
.../internals/InternalTopologyBuilder.java | 96 ++++++++++------------
.../internals/InternalStreamsBuilderTest.java | 10 +--
.../streams/kstream/internals/KStreamImplTest.java | 4 +-
.../internals/InternalTopologyBuilderTest.java | 55 ++++++++++---
.../processor/internals/StreamThreadTest.java | 2 +
.../apache/kafka/streams/TopologyTestDriver.java | 2 +-
6 files changed, 96 insertions(+), 73 deletions(-)
