kafka-storm-starter：代码示例显示了如何将Apache Kafka 0.8+与Apache Storm 0.9...
需积分: 9 107 浏览量
2021-02-05
21:55:02
上传
评论
收藏 242KB ZIP 举报
kafka-storm-starter-develop.zip （49个子文件） 
kafka-storm-starter-develop 
.travis.yml 603B sbt 19KB images 
IntelliJ-IDEA-Avro-bug.png 113KB IntelliJ-IDEA-Avro-bug_400x216.png 49KB sonar-project.properties 1KB assembly.sbt 2KB version.sbt 41B LICENSE 558B src test resources log4j.properties 569B logback-test.xml 5KB scala com miguno kafkastorm spark KafkaSparkStreamingSpec.scala 13KB testing EmbeddedKafkaZooKeeperCluster.scala 4KB storm serialization AvroSchemeSpec.scala 3KB FieldsEqualTo.scala 1KB bolts AvroDecoderBoltSpec.scala 6KB AvroKafkaSinkBoltSpec.scala 5KB kafka KafkaProducerAppSpec.scala 3KB integration StormSpec.scala 5KB IntegrationTest.scala 157B KafkaSpec.scala 6KB IntegrationSuite.scala 261B KafkaStormSpec.scala 13KB main resources producer-defaults.properties 6KB log4j.properties 6KB broker-defaults.properties 1KB consumer-defaults.properties 5KB avro twitter.avsc 450B scala com miguno kafkastorm spark serialization KafkaSparkStreamingRegistrator.scala 1KB zookeeper ZooKeeperEmbedded.scala 1KB storm topologies KafkaStormDemo.scala 5KB serialization AvroScheme.scala 3KB TweetAvroKryoDecorator.scala 462B bolts AvroKafkaSinkBolt.scala 5KB AvroDecoderBolt.scala 4KB utils StormRunner.scala 805B kafka KafkaConsumerApp.scala 5KB PooledKafkaProducerAppFactory.scala 2KB KafkaProducerApp.scala 4KB KafkaEmbedded.scala 4KB logging Logging.scala 286B build.sbt 6KB .gitignore 126B CHANGELOG.md 1KB .sbtopts 79B project plugins.sbt 781B assembly.sbt 57B build.sbt 98B build.properties 19B README.md 39KB资源评论
