Thanks Nathan for the explanation. Is there a way to get the actual no of messages processed in trident from the storm gui or using the storm api ?
On Sat, Sep 27, 2014 at 9:20 PM, Nathan Marz <[email protected]> wrote: > Trident executes a batch every 500ms (by default). A batch involves a > bunch of coordination messages going out to all the bolts to coordinate the > batch (even if the batch is empty). So that's what you're seeing. > > On Fri, Sep 26, 2014 at 12:32 PM, Deepak Subhramanian < > [email protected]> wrote: > >> Hi, >> I deployed a basic trident topology in HDP storm cluster. I am using >> >> TransactionalTridentKafkaSpout to process messages from Kafka Queue . For >> some reason the ack count in Storm GUI in spout and bolt increases by 20 >> every second even if there is no messages in Kafka queue . >> >> Is there any reason ack is called by Trident even though no messages are >> getting processed >> Thanks, D >> >> >> > > > > -- > Twitter: @nathanmarz > http://nathanmarz.com > -- Deepak Subhramanian
