优化diamante

java110

2021-10-19 b278a4b743d0cf45fd0b42bc78ff42f4e1124baf

 service-acct/src/main/java/com/java110/acct/kafka/AcctServiceKafka.java

@@ -31,7 +31,7 @@
    @Autowired
    private IAcctServiceSMO acctServiceSMOImpl;

    @KafkaListener(topics = {"userServiceTopic"})
    @KafkaListener(topics = {"acctServiceTopic"})
    public void listen(ConsumerRecord<?, ?> record) {
        logger.info("kafka的key: " + record.key());
        logger.info("kafka的value: " + record.value().toString());