Search Java Code Snippets


  Help us in improving the repository. Add new snippets through 'Submit Code Snippet ' link.





#Java - Code Snippets for '#Storm.kafka.bolt.KafkaBolt' - 1 code snippet(s) found

 Sample 1. Code Sample / Example / Snippet of org.apache.storm.kafka.bolt.KafkaBolt

    public StormTopology buildProducerTopology(Properties prop) {

TopologyBuilder builder = new TopologyBuilder();

builder.setSpout("spout", new RandomSentenceSpout(), 2);

KafkaBolt bolt = new KafkaBolt().withProducerProperties(prop)

.withTopicSelector(new DefaultTopicSelector("test"))

.withTupleToKafkaMapper(new FieldNameBasedTupleToKafkaMapper("key", "word"));

builder.setBolt("forwardToKafka", bolt, 1).shuffleGrouping("spout");

return builder.createTopology();

}


   Like      Feedback      org.apache.storm.kafka.bolt.KafkaBolt



Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner