Merge pull request #184 from igorcampos-dev/feature/adjustments-spring-wolf

feat(spring-wolf-example): update Kafka bindings and improve Dockerfi…

Author: igorcampos-dev

spring-wolf-example/.mvn/wrapper/maven-wrapper.properties

@@ -1,3 +1,3 @@
 wrapperVersion=3.3.4
 distributionType=only-script
-distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.12/apache-maven-3.9.12-bin.zip
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/4.0.0-rc-4/apache-maven-4.0.0-rc-4-bin.zip

spring-wolf-example/Dockerfile

@@ -16,7 +16,7 @@ COPY ./src src/
 RUN --mount=type=bind,source=pom.xml,target=pom.xml \
     --mount=type=cache,target=/root/.m2 \
     ./mvnw package -DskipTests && \
-    mv target/$(./mvnw help:evaluate -Dexpression=project.artifactId -q -DforceStdout)-$(./mvnw help:evaluate -Dexpression=project.version -q -DforceStdout).jar target/app.jar
+    mv target/*.jar target/app.jar
 
 FROM package as extract
 

spring-wolf-example/pom.xml

@@ -7,7 +7,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>3.5.10</version>
+		<version>4.0.2</version>
 		<relativePath/>
 	</parent>
 
@@ -19,8 +19,8 @@
 
     <properties>
 		<java.version>21</java.version>
-        <spring.boot.version>3.5.10</spring.boot.version>
-        <maven.plugin.version>3.15.0</maven.plugin.version>
+        <spring.boot.version>4.0.2</spring.boot.version>
+        <maven.plugin.version>4.0.0-beta-4</maven.plugin.version>
         <spring.cloud.kafka>5.0.1</spring.cloud.kafka>
         <lombok.version>1.18.42</lombok.version>
         <springwolf.version>2.0.0</springwolf.version>

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

@@ -5,16 +5,16 @@
 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.messaging.Message;
 import org.springframework.stereotype.Component;
 import java.util.function.Consumer;
 
 import static org.springframework.kafka.support.mapping.AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME;
 
 @Slf4j
-@Component
-public class KafkaConsumer implements Consumer<KafkaDto> {
+@Component("kafkaConsumer")
+public class KafkaConsumer implements Consumer<Message<KafkaDto>> {
 
     @KafkaAsyncOperationBinding(bindingVersion = "1.0.0")
     @AsyncListener(operation = @AsyncOperation(
@@ -31,7 +31,8 @@ public class KafkaConsumer implements Consumer<KafkaDto> {
                     })
     ))
     @Override
-    public void accept(KafkaDto kafkaDto) {
+    public void accept(Message<KafkaDto> message) {
+        var kafkaDto = message.getPayload();
         log.info("receive: {}", kafkaDto.message());
     }
 

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

@@ -36,7 +36,7 @@ public class KafkaProducer {
     @KafkaAsyncOperationBinding(bindingVersion = "1.0.0")
     public void send(String text) {
         KafkaDto message = new KafkaDto(text);
-        bridge.send("sendMessage-out-0", message);
+        bridge.send("kafkaV2Producer-out-0", message);
     }
 
 }

spring-wolf-example/src/main/resources/application.yaml

@@ -14,7 +14,7 @@ spring:
       bindings:
 
         # PRODUCER
-        sendMessage-out-0:
+        kafkaProducer-out-0:
           destination: ${kafka.topics.simple-topic}
 
         # CONSUMER