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