This commit is contained in:
@@ -3,7 +3,7 @@
|
||||
quarkus.datasource.db-kind=postgresql
|
||||
quarkus.datasource.username=postgres
|
||||
quarkus.datasource.password=password
|
||||
quarkus.datasource.jdbc.url=jdbc:postgresql://localhost:5432/eatery
|
||||
quarkus.datasource.jdbc.url=jdbc:postgresql://host.docker.internal:5432/postgres
|
||||
|
||||
## Tự động tạo bảng từ Entity (chỉ dùng cho môi trường dev)
|
||||
quarkus.hibernate-orm.database.generation=update
|
||||
@@ -32,4 +32,4 @@ quarkus.kafka.bootstrap-server=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal
|
||||
## Create restaurant topic
|
||||
mp.messaging.incoming.manager-in.connector=smallrye-kafka
|
||||
mp.messaging.incoming.manager-in.topic=create-restaurant
|
||||
mp.messaging.incoming.manager-in.value.deserializer=io.quarkus.kafka.client.serialization.ObjectMapperDeserializer
|
||||
mp.messaging.incoming.manager-in.value.deserializer=com.drinkool.config.ManagerCreateDeserializer
|
||||
@@ -26,6 +26,10 @@
|
||||
<artifactId>jackson-annotations</artifactId>
|
||||
<version>2.15.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.quarkus</groupId>
|
||||
<artifactId>quarkus-kafka-client</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>jakarta.persistence</groupId>
|
||||
<artifactId>jakarta.persistence-api</artifactId>
|
||||
|
||||
@@ -0,0 +1,14 @@
|
||||
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);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user