服务绑定开发选择服务环节

吴学文

2019-07-17 71bc98161c605c585fb9fd62ae84a735a3650e8b

 CommentService/src/main/java/com/java110/comment/kafka/CommentServiceKafka.java

@@ -12,6 +12,8 @@
import com.java110.core.context.BusinessServiceDataFlow;
import com.java110.core.factory.DataTransactionFactory;
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 CommentServiceKafka extends BaseController {

    protected final static Logger logger = LoggerFactory.getLogger(CommentServiceKafka.class);


    @Autowired
    private ICommentServiceSMO commentServiceSMOImpl;