屏蔽权限校验

shiyj

2019-07-07 93b5923477576b45400e890be6eb27ed7af71aea

 LogService/src/main/java/com/java110/log/kafka/LogServiceKafka.java

@@ -12,6 +12,8 @@
import com.java110.core.factory.DataTransactionFactory;
import com.java110.log.smo.ILogServiceSMO;
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;

@@ -41,10 +43,13 @@
 */
public class LogServiceKafka extends BaseController {

    private final static Logger logger = LoggerFactory.getLogger(LogServiceKafka.class);


    @Autowired
    private ILogServiceSMO logServiceSMOImpl;

    @KafkaListener(topics = {KafkaConstant.TOPIC_LOG_NAME})
    @KafkaListener(topics = {"LOG"})
    public void listen(ConsumerRecord<?, ?> record) {
        logger.info("LogServiceKafka receive message: {}", record.value().toString());
        String logMessage = record.value().toString();