优化 api 无法启动问题

wuxw

2019-09-20 9499873ee5b97bfd0aacf8d0895f56f437e6a93f

 StoreService/src/main/java/com/java110/store/kafka/StoreServiceKafka.java

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

@@ -23,11 +25,12 @@
 * Created by wuxw on 2018/4/15.
 */
public class StoreServiceKafka extends BaseController {
    private final static Logger logger = LoggerFactory.getLogger(StoreServiceKafka.class);

    @Autowired
    private IStoreServiceSMO storeServiceSMOImpl;

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