package com.qxueyou.scc.sys.service.impl; //import java.util.concurrent.TimeUnit; // //import org.junit.Test; //import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.kafka.core.KafkaTemplate; public class TestKafkaService { // @Autowired // private Listener listener; // // @Autowired // private KafkaTemplate template; // // @Test // public void testSimple() throws Exception { // template.send("annotated1", 0, "foo"); // template.flush(); //// assertTrue(this.listener.latch1.await(10, TimeUnit.SECONDS)); // } }