test2

michelin · Aug 27, 2024 · 651ff3c · 651ff3c
1 parent 4ee5ac2
commit 651ff3c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git 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<ConsumerGroupResetOffsetsResponse> 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
@@ -184,7 +184,7 @@ public Mono<HttpResponse<Void>> 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
@@ -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));
-Original file line number
+Diff line change
@@ Expand Up / @@ -184,7 +184,7 @@ public Mono<HttpResponse<Void>> delete(String namespace, @@
                                     sendEventLog(deletedSchema, ApplyStatus.deleted, deletedSchema.getSpec(), null,
                                         version.map(v -> "").orElseGet(() -> String.valueOf(deletedVersionIds)));
                                     return HttpResponse.noContent();
-                            });
+                                });
                     });
         }
@@ Expand Down @@