This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 99472c5 KAFKA-10158: Fix flaky
testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress (#9022)
add 0d47c69 KAFKA-10306: GlobalThread should fail on
InvalidOffsetException (#9075)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/GlobalStateMaintainer.java | 2 +-
.../internals/GlobalStateManagerImpl.java | 29 +++-------
.../processor/internals/GlobalStateUpdateTask.java | 24 ++++++--
.../processor/internals/GlobalStreamThread.java | 64 +++++++++++++++-------
.../internals/GlobalStateManagerImplTest.java | 16 ------
.../processor/internals/GlobalStateTaskTest.java | 28 ++++++++--
.../internals/GlobalStreamThreadTest.java | 46 +++++++++++-----
.../processor/internals/StateConsumerTest.java | 13 ++++-
.../apache/kafka/test/GlobalStateManagerStub.java | 10 +++-
.../apache/kafka/streams/TopologyTestDriver.java | 6 +-
10 files changed, 147 insertions(+), 91 deletions(-)
