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