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 1b588afb961 MINOR: Fix the link for the heading Errant Record Reporter
in connect.html (#20313)
add 03190e4c22a MINOR: retry upon missing source topic (#20284)
No new revisions were added by this update.
Summary of changes:
.../KStreamRepartitionIntegrationTest.java | 102 +++++++-----
.../streams/processor/internals/StreamThread.java | 45 +++++-
.../processor/internals/StreamThreadTest.java | 178 ++++++++++++++++++++-
3 files changed, 278 insertions(+), 47 deletions(-)
