From 3135709f0310489e9b1f25f8d5604fb8a086adeb Mon Sep 17 00:00:00 2001 From: Aditya Addepalli Date: Wed, 11 Jun 2025 12:57:42 -0500 Subject: [PATCH] GroupRebalanceConfig takes in rack id as an optional arg --- .../leaderelector/kafka/SchemaRegistryCoordinator.java | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/leaderelector/kafka/SchemaRegistryCoordinator.java b/core/src/main/java/io/confluent/kafka/schemaregistry/leaderelector/kafka/SchemaRegistryCoordinator.java index d8c07c0bc05..189d46451c5 100644 --- a/core/src/main/java/io/confluent/kafka/schemaregistry/leaderelector/kafka/SchemaRegistryCoordinator.java +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/leaderelector/kafka/SchemaRegistryCoordinator.java @@ -81,6 +81,7 @@ public SchemaRegistryCoordinator( heartbeatIntervalMs, groupId, Optional.empty(), + Optional.empty(), retryBackoffMs, retryBackoffMaxMs, true