You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Akshay Madhuranath <dm...@gmail.com> on 2015/06/08 16:15:48 UTC

Storm Trident for kafka not showing up proper emitted/transfered values in UI

Hello,

I am trying to use trident topology for Kafka i.e.
*TransactionalTridentKafkaSpout*. All works fine except the Storm UI. Even
though I've not produced any data to my topic, the Storm UI keeps showing
invalid emitted/transferred values. Meaning the count keeps on increasing
even when there is no data in the topic. I've tried deleting the data/logs
stored in zookeeper, storm, kafka and recreate kafka topics and also have
set *topology.stats.sample.rate: 1.0*
But Still the same problem persists.
I just read that "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".
Is there a way to get the acutal number of messages emitted/processed?

Thanks,
Akshay