@Component
public class KafkaRegisterEntryPoint implements CommandLineRunner {
@Autowired
ApplicationContext applicationContext;
@Override
public void run(String... args) throws Exception {
KafkaRegisterEvent kafkaRegisterEvent = new KafkaRegisterEvent();
applicationContext.publishEvent(kafkaRegisterEvent);
}
}
@Component
public class AA{
private static boolean flag = false;
@Async
@EventListener(KafkaRegisterEvent.class)
public void registerKafkaAndConnsume(KafkaRegisterEvent kafkaRegisterEvent) {
if(！flag){
flag = true
KafkaConsumer kc = new Kafkaconsumer();
while(true){
kc.comsum()
}
}
}
}
初始化注册kafka
标签：KafkaRegisterEvent,启动,class,kafka,flag,注册,public,kafkaRegisterEvent From： https://www.cnblogs.com/xiamingqing/p/17998859