This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 22db7b9f4c3 KAFKA-19683: More test replacements [5/N] (#20818)
add 9b0c9dbb101 KAFKA-19864: Handle TimeoutException from
initializeIfNeeded() in StateUpdater Code (#20829)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/TaskManager.java | 9 +++
.../processor/internals/TaskManagerTest.java | 90 +++++++++++++++-------
2 files changed, 73 insertions(+), 26 deletions(-)
