日志服务 编码生成服务测试通过

wuxw7

2018-06-17 288d590fbca6f7d884b7398d4c0e1921b04e128d

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

@@ -44,7 +44,7 @@
    @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();