spring boot集成kafka

[{"title":"（ 50 个子文件 43KB ） spring boot集成kafka","children":[{"title":"kafkaTest1","children":[{"title":".project <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest1","children":[{"title":"AppTest.java <span style='color:#111;'> 686B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 855B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest1","children":[{"title":"service","children":[{"title":"KafkaConsumerService.java <span style='color:#111;'> 343B </span>","children":null,"spread":false},{"title":"impl","children":[{"title":"KafkaConsumerServiceImpl.java <span style='color:#111;'> 555B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"App.java <span style='color:#111;'> 196B </span>","children":null,"spread":false},{"title":"kafka1Application.java <span style='color:#111;'> 3.14KB </span>","children":null,"spread":false},{"title":"component","children":[{"title":"Receiver.java <span style='color:#111;'> 383B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"target","children":[{"title":"classes","children":[{"title":"application.properties <span style='color:#111;'> 855B </span>","children":null,"spread":false},{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest1","children":[{"title":"service","children":[{"title":"KafkaConsumerService.class <span style='color:#111;'> 405B </span>","children":null,"spread":false},{"title":"impl","children":[{"title":"KafkaConsumerServiceImpl.class <span style='color:#111;'> 1.16KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"kafka1Application.class <span style='color:#111;'> 969B </span>","children":null,"spread":false},{"title":"component","children":[{"title":"Receiver.class <span style='color:#111;'> 761B </span>","children":null,"spread":false}],"spread":true},{"title":"App.class <span style='color:#111;'> 555B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"META-INF","children":[{"title":"MANIFEST.MF <span style='color:#111;'> 103B </span>","children":null,"spread":false},{"title":"maven","children":[{"title":"com.oscar","children":[{"title":"kafkaTest1","children":[{"title":"pom.properties <span style='color:#111;'> 227B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test-classes","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest1","children":[{"title":"AppTest.class <span style='color:#111;'> 627B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".settings","children":[{"title":"org.eclipse.m2e.core.prefs <span style='color:#111;'> 90B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 243B </span>","children":null,"spread":false},{"title":"org.eclipse.core.resources.prefs <span style='color:#111;'> 119B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false},{"title":".classpath <span style='color:#111;'> 1.05KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafkaTest","children":[{"title":".project <span style='color:#111;'> 561B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest","children":[{"title":"AppTest.java <span style='color:#111;'> 685B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"mian","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 325B </span>","children":null,"spread":false},{"title":"spring-kafka-consumer.xml <span style='color:#111;'> 3.10KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest","children":[{"title":"service","children":[{"title":"KafkaConsumerService.java <span style='color:#111;'> 342B </span>","children":null,"spread":false},{"title":"impl","children":[{"title":"KafkaConsumerServiceImpl.java <span style='color:#111;'> 553B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"App.java <span style='color:#111;'> 195B </span>","children":null,"spread":false},{"title":"kafkaApplication.java <span style='color:#111;'> 3.21KB </span>","children":null,"spread":false},{"title":"controller","children":[{"title":"testController.java <span style='color:#111;'> 516B </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"ServerConfig.java <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"target","children":[{"title":"classes","children":[{"title":"application.properties <span style='color:#111;'> 325B </span>","children":null,"spread":false},{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest","children":[{"title":"service","children":[{"title":"KafkaConsumerService.class <span style='color:#111;'> 404B </span>","children":null,"spread":false},{"title":"impl","children":[{"title":"KafkaConsumerServiceImpl.class <span style='color:#111;'> 1.15KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"controller","children":[{"title":"testController.class <span style='color:#111;'> 930B </span>","children":null,"spread":false}],"spread":true},{"title":"App.class <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"config","children":[{"title":"ServerConfig.class <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafkaApplication.class <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"META-INF","children":[{"title":"MANIFEST.MF <span style='color:#111;'> 103B </span>","children":null,"spread":false},{"title":"maven","children":[{"title":"com.oscar","children":[{"title":"kafkaTest","children":[{"title":"pom.properties <span style='color:#111;'> 224B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 1.61KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"spring-kafka-consumer.xml <span style='color:#111;'> 3.10KB </span>","children":null,"spread":false}],"spread":true},{"title":"test-classes","children":[{"title":"com","children":[{"title":"oscar","children":[{"title":"kafkaTest","children":[{"title":"AppTest.class <span style='color:#111;'> 625B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".settings","children":[{"title":"org.eclipse.m2e.core.prefs <span style='color:#111;'> 90B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 243B </span>","children":null,"spread":false},{"title":"org.eclipse.core.resources.prefs <span style='color:#111;'> 119B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.61KB </span>","children":null,"spread":false},{"title":".classpath <span style='color:#111;'> 906B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]