Hi, Dear all
I have tridentKafkaSpout and I want to test the throughput of it, develop a consumer to output the throughput is a method (Storm UI is another, but my topology only works in localmode, will diagnose it later). I can write a reduceAggregator to incrementally count all the tuples received, and how to setup the time windows to use get the number of tuples acked within that time slot, then will be able to get the throughput like No.of msg/sec. thanks Alec
