feat(spring-wolf): refactor Kafka topic handling and add utility class for constants

Author: igorcampos-dev

README.md

@@ -26,7 +26,7 @@ Below you will find a summary table of each subproject. For more details, please
 | [Spring Boot + Postgres](./spring-postgres-example)                       | Demonstrates a basic integration between Spring Boot and Postgres.                |
 | [Spring Boot + Mysql](./spring-mysql-example)                             | Demonstrates a basic integration between Spring Boot and Mysql.                   |
 | [Spring Boot + Grafana + Prometheus](./spring-prometheus-grafana-example) | Demonstrates a basic integration between Spring Boot With Grafana and Prometheus. |
-
+| [Spring Boot + Spring Wolf](./spring-wolf-example)                        | Demonstrates a basic integration between Spring Boot and Spring Wolf.             |
 ---
 
 ## Tech Stack

spring-wolf-example/compose.yaml

@@ -47,7 +47,7 @@ services:
     environment:
       KAFKA_HOST: kafka
       KAFKA_PORT: 9092
-      KAFKA_TOPIC_CREATE: spring-kafka-example-topic
+      KAFKA_TOPIC_CREATE: spring-kafka-simple-topic
     volumes:
       - type: bind
         source: ./docker/kafka/create_topic.sh

spring-wolf-example/src/main/java/com/io/example/consumer/KafkaConsumer.java

@@ -1,35 +1,33 @@
 package com.io.example.consumer;
 
 import com.io.example.dto.KafkaDto;
-import com.io.example.properties.KafkaProperties;
+import com.io.example.util.ConstantsUtil;
 import io.github.springwolf.bindings.kafka.annotations.KafkaAsyncOperationBinding;
 import io.github.springwolf.core.asyncapi.annotations.AsyncListener;
 import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
-
 import java.util.function.Consumer;
 
 import static org.springframework.kafka.support.mapping.AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME;
 
-
 @Slf4j
 @Component
 @RequiredArgsConstructor
 public class KafkaConsumer implements Consumer<KafkaDto> {
 
     @KafkaAsyncOperationBinding(bindingVersion = "1.0.0")
     @AsyncListener(operation = @AsyncOperation(
-            channelName = KafkaProperties.KAFKA_TOPIC,
+            channelName = ConstantsUtil.KAFKA_TOPIC,
             description = "Tópico que recebe dados de exemplo do kafka",
             servers = {"kafka"},
             headers = @AsyncOperation.Headers(
                     schemaName = "SpringKafkaDefaultHeaders-KafkaDto",
                     values = {
                             @AsyncOperation.Headers.Header(
                                     name = DEFAULT_CLASSID_FIELD_NAME,
-                                    value = "com.example.dto.KafkaDto",
+                                    value = "com.io.example.dto.KafkaDto",
                                     description = "Type ID")
                     })
     ))

spring-wolf-example/src/main/java/com/io/example/producer/KafkaProducer.java

@@ -1,6 +1,6 @@
 package com.io.example.producer;
 
-import com.io.example.properties.KafkaProperties;
+import com.io.example.util.ConstantsUtil;
 import com.io.example.dto.KafkaDto;
 import io.github.springwolf.bindings.kafka.annotations.KafkaAsyncOperationBinding;
 import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
@@ -20,15 +20,15 @@ public class KafkaProducer {
     @AsyncPublisher(
             operation = @AsyncOperation(
                     servers = {"kafka"},
-                    channelName = KafkaProperties.KAFKA_TOPIC,
+                    channelName = ConstantsUtil.KAFKA_TOPIC,
                     description = "Tópico de exemplo pra envio de mensagens",
                     payloadType = KafkaDto.class,
                     headers = @AsyncOperation.Headers(
                             schemaName = "SpringKafkaDefaultHeaders-KafkaDto",
                             values = {
                                     @AsyncOperation.Headers.Header(
                                             name = DEFAULT_CLASSID_FIELD_NAME,
-                                            value = "com.example.dto.KafkaDto",
+                                            value = "com.io.example.dto.KafkaDto",
                                             description = "Type ID")
                             })
             )

spring-wolf-example/src/main/java/com/io/example/properties/KafkaProperties.java

@@ -0,0 +1,5 @@
+package com.io.example.util;
+
+public class ConstantsUtil {
+    public static final String KAFKA_TOPIC = "spring-kafka-simple-topic";
+}