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 9e74f91e56 KAFKA-14089: Only check for committed seqnos after disabling exactly-once support in Connect integration test (#12429) add 2724cc9920 KAFKA-10199: Bookkeep tasks during assignment for use with state updater (#12442) No new revisions were added by this update. Summary of changes: .../streams/processor/internals/StreamThread.java | 17 ++- .../streams/processor/internals/TaskManager.java | 155 ++++++++++++++------- .../kafka/streams/processor/internals/Tasks.java | 21 +++ .../processor/internals/StreamThreadTest.java | 4 +- .../processor/internals/TaskManagerTest.java | 92 ++++++++---- .../org/apache/kafka/test/StreamsTestUtils.java | 23 --- 6 files changed, 212 insertions(+), 100 deletions(-)