package com.qxueyou.scc.sys.service.impl; //import java.util.concurrent.CountDownLatch; // //import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; @Component public class Listener { // // public final CountDownLatch latch1 = new CountDownLatch(1); // // @KafkaListener(id = "foo", topics = "annotated1") // public void listen1(String foo) { // this.latch1.countDown(); // } }