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 aaed164be63 MINOR: Refactor brokerContactTimesMs and
brokerRegistrationStates to use Long and Integer (#19888)
add 4d6cf3efef1 KAFKA-18913: Start state updater in task manager (#19889)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/StreamThread.java | 11 ++++---
.../streams/processor/internals/TaskManager.java | 5 +++
.../processor/internals/StreamThreadTest.java | 38 ++++++++++++++++++----
.../processor/internals/TaskManagerTest.java | 14 ++++++++
4 files changed, 57 insertions(+), 11 deletions(-)
