Minor refactoring and adding Mongo interceptor for logging (#10)

* using record instead of class

using records instead of class, so we can avoid constructors, getter, setter, toString and hashMap

* MongoDB interceptor for create flow

* instead of adding multiple events, making it to afterSave

Author: SVAdithya

src/main/java/com/kafka/learn/kafkastudy/interceptor/MongoLogInterceptor.java

@@ -0,0 +1,18 @@
+package com.kafka.learn.kafkastudy.interceptor;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.mongodb.core.mapping.event.AbstractMongoEventListener;
+import org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent;
+
+@Configuration
+public class MongoLogInterceptor extends AbstractMongoEventListener<Object> {
+	private static final Logger logger = LoggerFactory.getLogger(MongoLogInterceptor.class);
+
+	@Override
+	public void onAfterSave(AfterSaveEvent<Object> event) {
+		logger.info("Mongo Save Event {}, {}", event.getSource(), event);
+		// Events captured for this - [BeforeConvertEvent, BeforeSaveEvent, AfterSaveEvent]
+	}
+}

src/main/java/com/kafka/learn/kafkastudy/repository/dto/SuccessMessage.java

@@ -1,20 +1,14 @@
 package com.kafka.learn.kafkastudy.repository.dto;
 
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-import lombok.Setter;
 import org.springframework.data.annotation.Id;
 import org.springframework.data.mongodb.core.mapping.Document;
 
 @Document(collection = "successMessage")
-@Getter
-@Setter
-@AllArgsConstructor
-public class SuccessMessage {
-	@Id
-	private String id;
-	private String headers;
-	private String body;
-	private Long offset;
-	private String time;
+public record SuccessMessage(
+		@Id String id,
+		String headers,
+		String body,
+		Long offset,
+		String time
+) {
 }