Try this? https://github.com/wurstmeister/storm-kafka-0.8-plus-test/blob/master/src/main/java/storm/kafka/trident/SentenceAggregationTopology.java
On Fri, May 15, 2015 at 3:51 PM, Asif Ihsan <[email protected]> wrote: > That project doesn't do anything about message delivery. I have to make > sure guaranteed processing of the message sent by the spout to bolt. > > On Fri, May 15, 2015 at 5:33 PM, Jeffery Maass <[email protected]> wrote: > >> See the 0.9.4 release codebase @ >> https://github.com/apache/storm/tree/v0.9.4 >> There is a project called "Storm Starter" @ >> https://github.com/apache/storm/tree/v0.9.4/examples/storm-starter >> >> >> Thank you for your time! >> >> +++++++++++++++++++++ >> Jeff Maass <[email protected]> >> linkedin.com/in/jeffmaass >> stackoverflow.com/users/373418/maassql >> +++++++++++++++++++++ >> >> >> On Fri, May 15, 2015 at 2:43 AM, Asif Ihsan <[email protected]> >> wrote: >> >>> I am new to Storm. I studied that Storm is reliable and gives message >>> delivery guaranty. I tried to see how it works, but I couldn't do it. can >>> anyone help me with the single spout and single bolt. Every message sent by >>> the spout to bolt should be acknowledged by the bolt to the spout. And >>> display message that stream acknowledged. Thank you. >>> >>> -- >>> >>> >>> Regards >>> Muhammad Asif Ihsan >>> >> >> > > > -- > Regards > Muhammad Asif Ihsan >
