From 4dcf9a4e405e62a78e97ac31225824542ae9df64 Mon Sep 17 00:00:00 2001
From: javahongxi <javahongxi@qq.com>
Date: Mon, 24 Dec 2018 23:19:21 +0800
Subject: [PATCH] optimise

---
 .../main/java/org/hongxi/whatsmars/kafka/KafkaApplication.java  | 2 +-
 .../hongxi/whatsmars/boot/sample/kafka/KafkaApplication.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaApplication.java b/whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaApplication.java
index bd45445a..bfb947e6 100644
--- a/whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaApplication.java
+++ b/whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaApplication.java
@@ -13,7 +13,7 @@ import org.springframework.kafka.core.KafkaTemplate;
 public class KafkaApplication implements CommandLineRunner {
 
     @Autowired
-    private KafkaTemplate<Object, String> kafkaTemplate;
+    private KafkaTemplate<String, String> kafkaTemplate;
 
     public static void main(String[] args) {
         SpringApplication.run(KafkaApplication.class, args);
diff --git a/whatsmars-spring-boot-samples/whatsmars-boot-sample-kafka/src/main/java/org/hongxi/whatsmars/boot/sample/kafka/KafkaApplication.java b/whatsmars-spring-boot-samples/whatsmars-boot-sample-kafka/src/main/java/org/hongxi/whatsmars/boot/sample/kafka/KafkaApplication.java
index be0c7a18..0141f0e8 100644
--- a/whatsmars-spring-boot-samples/whatsmars-boot-sample-kafka/src/main/java/org/hongxi/whatsmars/boot/sample/kafka/KafkaApplication.java
+++ b/whatsmars-spring-boot-samples/whatsmars-boot-sample-kafka/src/main/java/org/hongxi/whatsmars/boot/sample/kafka/KafkaApplication.java
@@ -13,7 +13,7 @@ import org.springframework.kafka.core.KafkaTemplate;
 public class KafkaApplication implements CommandLineRunner {
 
     @Autowired
-    private KafkaTemplate<Object, String> kafkaTemplate;
+    private KafkaTemplate<String, String> kafkaTemplate;
 
     public static void main(String[] args) {
         SpringApplication.run(KafkaApplication.class, args);
-- 
GitLab