This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 3c4472d701a KAFKA-14867: Trigger rebalance when replica racks change
if client.rack is configured (KIP-881) (#13474)
add 0aa365add88 KAFKA-14838: Add flow/connector/task/role information to
MM2 Kafka client.id configs (#13458)
No new revisions were added by this update.
Summary of changes:
.../connect/mirror/MirrorCheckpointConfig.java | 15 ++++++----
.../connect/mirror/MirrorCheckpointConnector.java | 14 ++++++----
.../kafka/connect/mirror/MirrorCheckpointTask.java | 6 ++--
.../connect/mirror/MirrorCheckpointTaskConfig.java | 12 +++++++-
.../connect/mirror/MirrorConnectorConfig.java | 32 +++++++++++++++++-----
.../connect/mirror/MirrorHeartbeatConnector.java | 4 +--
.../apache/kafka/connect/mirror/MirrorMaker.java | 3 ++
.../kafka/connect/mirror/MirrorMakerConfig.java | 1 +
.../kafka/connect/mirror/MirrorSourceConfig.java | 15 ++++++----
.../connect/mirror/MirrorSourceConnector.java | 13 +++++----
.../kafka/connect/mirror/MirrorSourceTask.java | 2 +-
.../connect/mirror/MirrorSourceTaskConfig.java | 12 +++++++-
.../org/apache/kafka/connect/mirror/Scheduler.java | 4 +--
.../connect/mirror/MirrorCheckpointConfigTest.java | 19 +++++++++++--
.../connect/mirror/MirrorConnectorConfigTest.java | 26 ++++++++++++------
.../connect/mirror/MirrorMakerConfigTest.java | 2 ++
.../connect/mirror/MirrorSourceConfigTest.java | 31 +++++++++++++++++----
.../connect/mirror/MirrorSourceMetricsTest.java | 1 +
.../org/apache/kafka/connect/mirror/TestUtils.java | 10 +++++++
.../runtime/distributed/DistributedHerder.java | 9 ++++--
20 files changed, 172 insertions(+), 59 deletions(-)
