diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/SchemaRegistryCoordinator.java b/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/SchemaRegistryCoordinator.java index ae5f6222a6d9..b14d8633ebec 100644 --- a/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/SchemaRegistryCoordinator.java +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/SchemaRegistryCoordinator.java @@ -77,8 +77,8 @@ public SchemaRegistryCoordinator( metrics, metricGrpPrefix, time, - retryBackoffMs, - true); + retryBackoffMs + ); this.identity = identity; this.assignmentSnapshot = null; this.listener = listener;