Description: storm+kafka+matlb integration testing, due to the jar is too big, jar not uploaded
To Search:
File list (Check if you may need any files):
calabarstorm\.classpath
............\.fatjar
............\.project
............\.settings\org.eclipse.core.resources.prefs
............\.........\org.eclipse.jdt.core.prefs
............\resource\storm.properties
............\src\com\calabar\bean\TopoConfig.java
............\...\...\.......\.olt\CountBoltForConcurrency.java
............\...\...\.......\....\FileWriterBolt.java
............\...\...\.......\....\SplitBolt.java
............\...\...\.......\....\SpliterBolt.java
............\...\...\.......\spout\MessageSpout.java
............\...\...\.......\.....\ProduceSpout.java
............\...\...\.......\topology\DemoTopology.java
............\...\...\.......\........\DemoTopologyRepeatFailure.java
............\...\...\.......\........\DemoTopologySimple.java
............\...\...\.......\........\TransactionalWords.java
............\...\...\.......\........\TridentReach.java
............\...\...\.......\........\TridentWordCount.java
............\...\...\.......\utils\PropertiesUtil.java
............\...\...\.......\.....\SendMessage2.java
............\...\...\.......\bean
............\...\...\.......\bolt
............\...\...\.......\spout
............\...\...\.......\topology
............\...\...\.......\utils
............\...\...\calabar
............\...\com
............\.settings
............\resource
............\src
calabarstorm
Download