java操作kafka，包括发送和接收任务

基于springcloud的微服务工程，可以直接运行。

package kafkaserver;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class ConsumerTest {

	public static void main（String[] args） {

        
        ApplicationContext context = new AnnotationConfigApplicationContext（KafkaConsumer.class）;

        
    }


}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2020-04-24 02:36  kafkaserver\
     文件        2724  2020-04-24 02:36  kafkaserver\pom.xml
     文件         540  2020-04-24 02:36  kafkaserver\.project
     文件        1479  2020-04-24 02:36  kafkaserver\.classpath
     目录           0  2020-04-24 02:36  kafkaserver\target\
     文件        9888  2020-04-24 02:36  kafkaserver\target\kafkaserver-0.0.1-SNAPSHOT.jar
     文件    10782719  2020-04-24 02:36  kafkaserver\target\kafkaserver-0.0.1-SNAPSHOT-jar-with-dependencies.jar
     目录           0  2020-04-24 02:36  kafkaserver\src\
     目录           0  2020-04-24 02:36  kafkaserver\.settings\
     文件          86  2020-04-24 02:36  kafkaserver\.settings\org.eclipse.m2e.core.prefs
     文件         699  2020-04-24 02:36  kafkaserver\.settings\org.eclipse.jdt.core.prefs
     目录           0  2020-04-24 02:36  kafkaserver\target\test-classes\
     目录           0  2020-04-24 02:36  kafkaserver\target\maven-status\
     目录           0  2020-04-24 02:36  kafkaserver\target\maven-archiver\
     文件         111  2020-04-24 02:36  kafkaserver\target\maven-archiver\pom.properties
     目录           0  2020-04-24 02:36  kafkaserver\target\classes\
     目录           0  2020-04-24 02:36  kafkaserver\target\archive-tmp\
     目录           0  2020-04-24 02:36  kafkaserver\src\test\
     目录           0  2020-04-24 02:36  kafkaserver\src\main\
     目录           0  2020-04-24 02:36  kafkaserver\target\maven-status\maven-compiler-plugin\
     目录           0  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\
     文件        3996  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\KafkaProducer.class
     文件        1246  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\KafkaProducer$FailCallBack.class
     文件         742  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\KafkaProducer$CallBackSuccess.class
     文件        3341  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\KafkaConsumer.class
     文件        2605  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\Group2Listener.class
     文件        2371  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\Group1Listener.class
     文件         660  2020-04-24 02:36  kafkaserver\target\classes\kafkaserver\ConsumerTest.class
     目录           0  2020-04-24 02:36  kafkaserver\target\classes\meta-INF\
     文件         106  2020-04-24 02:36  kafkaserver\target\classes\meta-INF\MANIFEST.MF
     目录           0  2020-04-24 02:36  kafkaserver\src\test\resources\
............此处省略21个文件信息