Hi Tao,

Yes this is the intended behavior, since it only queries the consumer
coordinator's in-memory cache about the consumer group metadata, which only
contains active consumer groups, if a group has no live members any more it
is treated as dead and removed from cache.

To get committed offsets from all groups that has not expired you can use
console consumer to directly fetch the offset topic from Kafka:

bin/kafka-console-consumer.sh --consumer.config config/consumer.properties
--from-beginning --topic __consumer_offsets --zookeeper localhost:2181
--formatter
"kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter"

Guozhang

On Wed, Nov 25, 2015 at 4:53 AM, tao xiao <xiaotao...@gmail.com> wrote:

> Hi team,
>
> In 0.9.0.0 a new tool kafka-consumer-groups.sh is introduced to show offset
> and lag for a particular consumer group prefer over the old
> one kafka-consumer-offset-checker.sh. However I found that the new tool
> only works for consumer groups that are currently active but not for
> consumer groups that ever connected to the broker.  I wonder if this is
> intended behavior. If yes how do query non-active consumer group committed
> offset besides using kafka-consumer-offset-checker.sh
>



-- 
-- Guozhang

Reply via email to