diff --git a/src/main/java/com/michelin/ns4kafka/controller/ConsumerGroupController.java b/src/main/java/com/michelin/ns4kafka/controller/ConsumerGroupController.java index 502ee721..22684592 100644 --- a/src/main/java/com/michelin/ns4kafka/controller/ConsumerGroupController.java +++ b/src/main/java/com/michelin/ns4kafka/controller/ConsumerGroupController.java @@ -86,7 +86,8 @@ public List resetOffsets(String namespace, St consumerGroupResetOffsets.getSpec().getMethod()); if (!dryrun) { - sendEventLog(consumerGroupResetOffsets, ApplyStatus.changed, null, consumerGroupResetOffsets.getSpec(), ""); + sendEventLog(consumerGroupResetOffsets, ApplyStatus.changed, null, + consumerGroupResetOffsets.getSpec(), ""); consumerGroupService.alterConsumerGroupOffsets(ns, consumerGroup, preparedOffsets); } diff --git a/src/main/java/com/michelin/ns4kafka/controller/SchemaController.java b/src/main/java/com/michelin/ns4kafka/controller/SchemaController.java index 13535c48..b1009c49 100644 --- a/src/main/java/com/michelin/ns4kafka/controller/SchemaController.java +++ b/src/main/java/com/michelin/ns4kafka/controller/SchemaController.java @@ -184,7 +184,7 @@ public Mono> delete(String namespace, sendEventLog(deletedSchema, ApplyStatus.deleted, deletedSchema.getSpec(), null, version.map(v -> "").orElseGet(() -> String.valueOf(deletedVersionIds))); return HttpResponse.noContent(); - }); + }); }); } diff --git a/src/test/java/com/michelin/ns4kafka/service/SchemaServiceTest.java b/src/test/java/com/michelin/ns4kafka/service/SchemaServiceTest.java index d3c1df6b..a6e25fb2 100644 --- a/src/test/java/com/michelin/ns4kafka/service/SchemaServiceTest.java +++ b/src/test/java/com/michelin/ns4kafka/service/SchemaServiceTest.java @@ -297,9 +297,6 @@ void shouldDeleteSchemaAllVersions() { @Test void shouldDeleteSchemaSpecificVersion() { Namespace namespace = buildNamespace(); - SchemaResponse schemaResponse = buildSchemaResponse("prefix.schema-one-value"); - SchemaCompatibilityResponse compatibilityResponse = buildCompatibilityResponse(); - when(schemaRegistryClient.deleteSubjectVersion(namespace.getMetadata().getCluster(), "prefix.schema-one-value", "2", false)).thenReturn(Mono.just(2));