I have a simple stream setup which reads a source topic and forks to an
aggregation with its own statestore, and a flatmap().to("topic1") and that
topic is read in to a global state store.I use ConsumerGroupCommand to query for the lag of each consumer on the topics. https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala It seems like ConsumerGroupCommand only shows some consumers, but not all. I can see the consumer for the original source topic, but I don't see one for 'topic1', yet the globalstatestore is populated. How can I see the lag of the globalstatestore consumer?
