This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from f7eb96230d5 MINOR: Replaced the while loop with
TestUtils.waitForCondition (#15678)
add a1ca788c993 KAFKA-15517: Improve MirrorMaker logging in case of
authorization errors (#15558)
No new revisions were added by this update.
Summary of changes:
.../connect/mirror/MirrorCheckpointConnector.java | 12 +-
.../kafka/connect/mirror/MirrorCheckpointTask.java | 57 +++---
.../connect/mirror/MirrorSourceConnector.java | 205 +++++++++++++--------
.../apache/kafka/connect/mirror/MirrorUtils.java | 20 ++
.../connect/mirror/MirrorCheckpointTaskTest.java | 5 +-
.../connect/mirror/MirrorSourceConnectorTest.java | 40 +++-
6 files changed, 236 insertions(+), 103 deletions(-)
