This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 2c0cab39aed MINOR: Remove unnecessary easymock/powermock dependencies
(#15460)
add 7dbdc15c668 KAFKA-15625: Do not flush global state store at each
commit (#15361)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/GlobalStateMaintainer.java | 2 +
.../processor/internals/GlobalStateUpdateTask.java | 20 +++-
.../processor/internals/GlobalStreamThread.java | 25 ++---
.../processor/internals/GlobalStateTaskTest.java | 111 +++++++++++++++++++--
.../processor/internals/StateConsumerTest.java | 31 ++----
.../apache/kafka/test/GlobalStateManagerStub.java | 10 +-
.../apache/kafka/streams/TopologyTestDriver.java | 4 +-
7 files changed, 147 insertions(+), 56 deletions(-)
