fixed spring examples

Author: hifly81

kafka-springboot-consumer/pom.xml

@@ -11,6 +11,13 @@
 
     <artifactId>kafka-springboot-consumer</artifactId>
 
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <spring.kafka.version>2.9.11</spring.kafka.version>
+    </properties>
+
+
     <dependencies>
 
         <dependency>
@@ -36,7 +43,7 @@
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
-            <version>2.9.11</version>
+            <version>${spring.kafka.version}</version>
         </dependency>
 
     </dependencies>

kafka-springboot-consumer/src/main/java/org/hifly/demo/kafka/kafka/KafkaReceiverConfig.java

@@ -4,6 +4,7 @@
 import org.hifly.demo.kafka.mongo.OrderRepository;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.messaging.handler.annotation.Payload;

kafka-springboot-consumer/src/main/java/org/hifly/demo/kafka/kafka/Receiver.java

@@ -11,6 +11,12 @@
 
     <artifactId>kafka-springboot-producer</artifactId>
 
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <spring.kafka.version>2.9.11</spring.kafka.version>
+    </properties>
+
     <dependencies>
 
         <dependency>
@@ -31,7 +37,7 @@
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
-            <version>2.9.11</version>
+            <version>${spring.kafka.version}</version>
         </dependency>
 
     </dependencies>

kafka-springboot-producer/pom.xml

@@ -1,6 +1,7 @@
 package org.hifly.demo.kafka.controller;
 
 import org.hifly.demo.kafka.model.Order;
+import org.hifly.demo.kafka.controller.kafka.Producer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,7 +20,7 @@ public class KafkaRestController {
 	private final Producer producer;
 
 	@Autowired
-	KafkaController(Producer producer) {
+	public KafkaRestController(Producer producer) {
 		this.producer = producer;
 	}
 

kafka-springboot-producer/src/main/java/org/hifly/demo/kafka/controller/KafkaRestController.java

@@ -1,4 +1,4 @@
-package org.hifly.demo.kafka.controller.kafka:
+package org.hifly.demo.kafka.controller.kafka;
 
 import org.springframework.kafka.support.SendResult;
 import org.apache.kafka.clients.producer.ProducerRecord;
@@ -42,7 +42,7 @@ public void onSuccess(final SendResult<String, String> result) {
 
                 @Override
                 public void onFailure(final Throwable throwable) {
-                    logger.error("onFailure --> unable to send: " + order, throwable);
+                    logger.error("onFailure --> unable to send: " + message, throwable);
                 }
             });
         } catch(Exception ex) {

kafka-springboot-producer/src/main/java/org/hifly/demo/kafka/kafka/Producer.java

@@ -34,7 +34,7 @@
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
-      <version>4.12</version>
+      <version>4.13.1</version>
       <scope>test</scope>
       <exclusions>
         <exclusion>

kafka-streams/dependency-reduced-pom.xml

@@ -39,7 +39,7 @@
         <apicurio.registry.version>2.4.1.Final</apicurio.registry.version>
         <hortonworks.registry.version>0.3.0</hortonworks.registry.version>
         <slf4j.version>1.7.15</slf4j.version>
-        <junit.version>4.12</junit.version>
+        <junit.version>4.13.1</junit.version>
         <curator.version>5.0.0</curator.version>
         <minio.version>8.5.2</minio.version>
         <jackson.version>2.12.7.1</jackson.version>