Fixed logs when a schema is applied (#205)

Author: Loïc GREFFIER

api/src/main/java/com/michelin/ns4kafka/controllers/SchemaController.java

@@ -17,6 +17,8 @@
 
 import javax.inject.Inject;
 import javax.validation.Valid;
+import java.time.Instant;
+import java.util.Date;
 import java.util.List;
 import java.util.Optional;
 
@@ -103,6 +105,10 @@ public Single<HttpResponse<Schema>> apply(String namespace, @Valid @Body Schema
                                     .map(id -> {
                                         ApplyStatus status;
 
+                                        schema.getMetadata().setCreationTimestamp(Date.from(Instant.now()));
+                                        schema.getMetadata().setCluster(ns.getMetadata().getCluster());
+                                        schema.getMetadata().setNamespace(ns.getMetadata().getName());
+
                                         if (latestSubjectOptional.isEmpty()) {
                                             status = ApplyStatus.created;
                                             sendEventLog(schema.getKind(), schema.getMetadata(), status, null, schema.getSpec());

api/src/main/java/com/michelin/ns4kafka/services/executors/ConnectorAsyncExecutor.java

@@ -163,7 +163,7 @@ private List<Connector> collectNs4KafkaConnectors(String connectCluster) {
                 .stream()
                 .filter(connector -> connector.getSpec().getConnectCluster().equals(connectCluster))
                 .collect(Collectors.toList());
-        log.debug("Connectors found on Ns4kafka for Connect Cluster {} : {}", connectCluster, connectorList.size());
+        log.debug("Connectors found on Ns4kafka for Connect Cluster {}: {}", connectCluster, connectorList.size());
         return connectorList;
     }
 

api/src/main/java/com/michelin/ns4kafka/services/executors/TopicAsyncExecutor.java

@@ -200,10 +200,10 @@ private void alterTopics(Map<ConfigResource, Collection<AlterConfigOp>> toUpdate
                         updatedTopic.getMetadata().setCreationTimestamp(Date.from(Instant.now()));
                         updatedTopic.getMetadata().setGeneration(updatedTopic.getMetadata().getGeneration()+1);
                         updatedTopic.setStatus(Topic.TopicStatus.ofSuccess("Topic configs updated"));
-                        log.info("Success updating topic configs {} on {} : [{}]",
+                        log.info("Success updating topic configs {} on {}: [{}]",
                                 mapEntry.getKey().name(),
-                                this.kafkaAsyncExecutorConfig.getName(),
-                                ops.stream().map(alterConfigOp -> alterConfigOp.toString()).collect(Collectors.joining(",")));
+                                kafkaAsyncExecutorConfig.getName(),
+                                ops.stream().map(AlterConfigOp::toString).collect(Collectors.joining(",")));
                     } catch (InterruptedException e) {
                         log.error("Error", e);
                         Thread.currentThread().interrupt();