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