Yes, I can do that from java with something like,
*ConsumerGroupCommand.main(new String[]{"--new-consumer",
"--bootstrap-server", "localhost:9092","--describe", "--group",
"testgroup"});*
But how do i process the output as it does not return anything?
Thanks,
Sumit
On Wed, Feb 8, 2017 at 10:38 PM, R Krishna <krishna...@gmail.com> wrote:
> You can run the same class executed in the scripts.
> On Feb 8, 2017 8:50 AM, "Sumit Maheshwari" <sumitm.i...@gmail.com> wrote:
>
> > Hi,
> >
> > Currently in 0.10 we can get the information about the consumer groups
> and
> > respective lag using the kafka-consumer-groups.sh.
> > Is there a way to achieve the same programatically in java?
> >
> > Thanks,
> > Sumit
> >
>
