chore: update

eatery-service/pom.xml

@@ -1,8 +1,8 @@
-<?xml version="1.0" encoding="UTF-8" ?>
+<?xml version="1.0" encoding="UTF-8"?>
 <project
-	xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
+    xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
 >
     <modelVersion>4.0.0</modelVersion>
 
@@ -20,11 +20,9 @@
         <compiler-plugin.version>3.15.0</compiler-plugin.version>
         <maven.compiler.release>25</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <project.reporting.outputEncoding
-		>UTF-8</project.reporting.outputEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
-        <quarkus.platform.group-id
-		>io.quarkus.platform</quarkus.platform.group-id>
+        <quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
         <quarkus.platform.version>3.32.4</quarkus.platform.version>
         <skipITs>true</skipITs>
         <surefire-plugin.version>3.5.4</surefire-plugin.version>
@@ -128,8 +126,7 @@
                 <configuration>
                     <argLine>@{argLine}</argLine>
                     <systemPropertyVariables>
-                        <java.util.logging.manager
-						>org.jboss.logmanager.LogManager</java.util.logging.manager>
+                        <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
                         <maven.home>${maven.home}</maven.home>
                     </systemPropertyVariables>
                     <forkCount>1</forkCount>
@@ -153,8 +150,7 @@
                     <systemPropertyVariables>
                         <native.image.path>
                             ${project.build.directory}/${project.build.finalName}-runner</native.image.path>
-                        <java.util.logging.manager
-						>org.jboss.logmanager.LogManager</java.util.logging.manager>
+                        <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
                         <maven.home>${maven.home}</maven.home>
                     </systemPropertyVariables>
                 </configuration>
@@ -177,4 +173,4 @@
             </properties>
         </profile>
     </profiles>
-</project>
+</project>

eatery-service/src/main/resources/application.properties

@@ -33,4 +33,4 @@ mp.messaging.connector.smallrye-kafka.bootstrap.servers=${KAFKA_SERVICE_SERVICE_
 mp.messaging.incoming.manager-in.connector=smallrye-kafka
 mp.messaging.incoming.manager-in.topic=create-restaurant
 mp.messaging.incoming.manager-in.auto.offset.reset=earliest
-mp.messaging.incoming.manager-in.value.deserializer=com.drinkool.config.ManagerCreateDeserializer
+quarkus.kafka.deserialization.manager-in.type=com.drinkool.dtos.event.ManagerCreate

k8s/kafdrop.yaml

@@ -0,0 +1,35 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: kafdrop
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: kafdrop
+  template:
+    metadata:
+      labels:
+        app: kafdrop
+    spec:
+      containers:
+      - name: kafdrop
+        image: obsidiandynamics/kafdrop
+        ports:
+        - containerPort: 9000
+        env:
+        - name: KAFKA_BROKERCONNECT
+          value: "kafka-service:9092" # Trỏ vào service Kafka của bạn
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: kafdrop-svc
+spec:
+  type: NodePort
+  selector:
+    app: kafdrop
+  ports:
+  - protocol: TCP
+    port: 9000
+    nodePort: 30900

lib/pom.xml

@@ -30,6 +30,12 @@
         <groupId>io.quarkus</groupId>
         <artifactId>quarkus-kafka-client</artifactId>
     </dependency>
+    <dependency>
+        <groupId>org.projectlombok</groupId>
+        <artifactId>lombok</artifactId>
+        <version>1.18.30</version>
+        <scope>provided</scope>
+    </dependency>
     <dependency>
       <groupId>jakarta.persistence</groupId>
       <artifactId>jakarta.persistence-api</artifactId>

lib/src/main/java/com/drinkool/config/ManagerCreateDeserializer.java

@@ -1,14 +0,0 @@
-package com.drinkool.config;
-
-import com.drinkool.dtos.event.ManagerCreate;
-import io.quarkus.kafka.client.serialization.ObjectMapperDeserializer;
-
-// Bạn kế thừa và chỉ định rõ Type ở đây
-public class ManagerCreateDeserializer
-	extends ObjectMapperDeserializer<ManagerCreate>
-{
-
-	public ManagerCreateDeserializer() {
-		super(ManagerCreate.class);
-	}
-}

lib/src/main/java/com/drinkool/dtos/event/ManagerCreate.java

@@ -1,11 +1,17 @@
 package com.drinkool.dtos.event;
 
+import io.quarkus.runtime.annotations.RegisterForReflection;
 import java.util.UUID;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
 
+@RegisterForReflection
+@Getter
+@Setter
+@NoArgsConstructor
 public class ManagerCreate {
 
 	public UUID id;
 	public String eateryName;
-
-	public ManagerCreate() {}
 }