@Test
public void testRunTopology() throws InterruptedException {

    Configuration conf = new Configuration();
    TrendingTopics topology = new TrendingTopics("tt", conf);
    
    StormRunner.runTopologyLocally(topology.buildTopology(), "tt", conf, 100);
}