优化代码

java110

2021-05-05 c688e26e42b26385eb918d52d83a851d3bc6a1a1

 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());