From 348c483d9e8cf81c485289a44c717fe1c23f4065 Mon Sep 17 00:00:00 2001
From: shiyj <1098226878@qq.com>
Date: 星期日, 07 七月 2019 17:29:35 +0800
Subject: [PATCH] Merge branch 'master' of https://github.com/java110/MicroCommunity
---
CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java | 5 +++++
1 files changed, 5 insertions(+), 0 deletions(-)
diff --git a/CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java b/CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java
index 396343e..8cd4b97 100644
--- a/CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java
+++ b/CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java
@@ -12,6 +12,8 @@
import com.java110.core.factory.DataTransactionFactory;
import com.java110.community.smo.ICommunityServiceSMO;
import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
@@ -24,6 +26,9 @@
*/
public class CommunityServiceKafka extends BaseController {
+ private final static Logger logger = LoggerFactory.getLogger(CommunityServiceKafka.class);
+
+
@Autowired
private ICommunityServiceSMO communityServiceSMOImpl;
--
Gitblit v1.8.0