kafka demo ，两种线程消费方式

[{"title":"（ 35 个子文件 24KB ） kafka demo ，两种线程消费方式","children":[{"title":"kafka","children":[{"title":"pom.xml <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"target","children":[{"title":"test-classes","children":null,"spread":false},{"title":"m2e-wtp","children":[{"title":"web-resources","children":[{"title":"META-INF","children":[{"title":"maven","children":[{"title":"com.vaj","children":[{"title":"kafka","children":[{"title":"pom.xml <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"pom.properties <span style='color:#111;'> 203B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"MANIFEST.MF <span style='color:#111;'> 103B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"classes","children":[{"title":"com","children":[{"title":"kafka","children":[{"title":"base","children":[{"title":"KafkaProducerDemo.class <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false},{"title":"KafkaConsumerDemo.class <span style='color:#111;'> 2.55KB </span>","children":null,"spread":false}],"spread":true},{"title":"advance","children":[{"title":"type1","children":[{"title":"KafkaProducerThread$1.class <span style='color:#111;'> 1.49KB </span>","children":null,"spread":false},{"title":"KafakaConsumerGroupMain.class <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"KafkaConsumerThread.class <span style='color:#111;'> 3.04KB </span>","children":null,"spread":false},{"title":"KafkaConsumerGroup.class <span style='color:#111;'> 1.48KB </span>","children":null,"spread":false},{"title":"KafkaProducerThread.class <span style='color:#111;'> 2.70KB </span>","children":null,"spread":false}],"spread":true},{"title":"type2","children":[{"title":"KafkaConsumerThreadHandler.class <span style='color:#111;'> 1.45KB </span>","children":null,"spread":false},{"title":"KafkaConsumerThread.class <span style='color:#111;'> 3.32KB </span>","children":null,"spread":false},{"title":"KafkaConsumerThreadMain.class <span style='color:#111;'> 1.07KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"connector","children":null,"spread":false}],"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.wst.jsdt.ui.superType.name <span style='color:#111;'> 6B </span>","children":null,"spread":false},{"title":"org.eclipse.wst.common.project.facet.core.xml <span style='color:#111;'> 252B </span>","children":null,"spread":false},{"title":"org.eclipse.wst.common.component <span style='color:#111;'> 740B </span>","children":null,"spread":false},{"title":"org.eclipse.wst.jsdt.ui.superType.container <span style='color:#111;'> 49B </span>","children":null,"spread":false},{"title":"org.eclipse.wst.validation.prefs <span style='color:#111;'> 50B </span>","children":null,"spread":false},{"title":".jsdtscope <span style='color:#111;'> 639B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 478B </span>","children":null,"spread":false}],"spread":true},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":null,"spread":false}],"spread":true},{"title":"main","children":[{"title":"webapp","children":[{"title":"WEB-INF","children":[{"title":"web.xml <span style='color:#111;'> 222B </span>","children":null,"spread":false}],"spread":true},{"title":"index.jsp <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"resources","children":null,"spread":false},{"title":"java","children":[{"title":"com","children":[{"title":"kafka","children":[{"title":"base","children":[{"title":"KafkaConsumerDemo.java <span style='color:#111;'> 1.53KB </span>","children":null,"spread":false},{"title":"KafkaProducerDemo.java <span style='color:#111;'> 2.65KB </span>","children":null,"spread":false}],"spread":true},{"title":"advance","children":[{"title":"type1","children":[{"title":"KafakaConsumerGroupMain.java <span style='color:#111;'> 751B </span>","children":null,"spread":false},{"title":"KafkaConsumerGroup.java <span style='color:#111;'> 1013B </span>","children":null,"spread":false},{"title":"KafkaConsumerThread.java <span style='color:#111;'> 1.75KB </span>","children":null,"spread":false},{"title":"KafkaProducerThread.java <span style='color:#111;'> 2.14KB </span>","children":null,"spread":false}],"spread":false},{"title":"type2","children":[{"title":"KafkaConsumerThreadMain.java <span style='color:#111;'> 654B </span>","children":null,"spread":false},{"title":"KafkaConsumerThreadHandler.java <span style='color:#111;'> 538B </span>","children":null,"spread":false},{"title":"KafkaConsumerThread.java <span style='color:#111;'> 1.97KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"connector","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".project <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":".classpath <span style='color:#111;'> 1.15KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]