KafkaTestDataProducer:产生随机消息并发送到 kafka-源码

[{"title":"（ 12 个子文件 9KB ） KafkaTestDataProducer:产生随机消息并发送到 kafka-源码","children":[{"title":"KafkaTestDataProducer-master","children":[{"title":"README.md <span style='color:#111;'> 308B </span>","children":null,"spread":false},{"title":"Kafka","children":[{"title":"KafkaProducer","children":[{"title":".project <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"assemble","children":[{"title":"appPackage.xml <span style='color:#111;'> 1.26KB </span>","children":null,"spread":false}],"spread":true},{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"datatorrent","children":[{"title":"KafkaProducer","children":[{"title":"KafkaDataProducer.java <span style='color:#111;'> 2.92KB </span>","children":null,"spread":false},{"title":"KafkaPartitioner.java <span style='color:#111;'> 360B </span>","children":null,"spread":false},{"title":"KafkaProducer.java <span style='color:#111;'> 359B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".settings","children":[{"title":"org.eclipse.m2e.core.prefs <span style='color:#111;'> 86B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 238B </span>","children":null,"spread":false},{"title":"org.eclipse.core.resources.prefs <span style='color:#111;'> 115B </span>","children":null,"spread":false}],"spread":true},{"title":"META-INF","children":[{"title":"MANIFEST.MF <span style='color:#111;'> 187B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.14KB </span>","children":null,"spread":false},{"title":".classpath <span style='color:#111;'> 996B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]