how to create consumer group in tridentKafkaSpout

[Sa Li <sa...@gmail.com>]

Hi, all

I am running a topology which has a tridentKafkaSpout to consume the
messages from kafka. In general, kafka consumers can track the maximum
offset they have consumed in each partition, which I can view in zk

/consumers/group_id/offsets/topic/brokerid_partition_id

However, how I can keep track of the consumer offset for a particular
topic, cause basically I want to know how many records have been
acked/consumed by storm, that is similar to consumer offset, how do I do
that?

thanks


AL