I wrote the consumer by myself in golang using Shopify's sarama lib updated
of master branch.

On Fri, Feb 19, 2016 at 4:03 PM, tao xiao <xiaotao...@gmail.com> wrote:

> which version of consumer do you use?
>
>
> On Fri, 19 Feb 2016 at 15:26 Amoxicillin <shee...@gmail.com> wrote:
>
> > I tried as you suggested, but still no output of any group info.
> >
> > On Fri, Feb 19, 2016 at 2:45 PM, tao xiao <xiaotao...@gmail.com> wrote:
> >
> > > That is what I mean alive.  If you use new consumer connecting to
> broker
> > > you should use --new-consumer option to list all consumer groups
> > >
> > > kafka-run-class.sh kafka.admin.ConsumerGroupCommand --list
> --new-consumer
> > > --bootstrap-server localhost:9092
> > >
> > > On Fri, 19 Feb 2016 at 14:18 Amoxicillin <shee...@gmail.com> wrote:
> > >
> > > > How to confirm the consumer groups are alive? I have one consumer in
> > the
> > > > group running at the same time, and could get messages correctly.
> > > >
> > > > On Fri, Feb 19, 2016 at 1:40 PM, tao xiao <xiaotao...@gmail.com>
> > wrote:
> > > >
> > > > > when using ConsumerGroupCommand you need to make sure your consumer
> > > > groups
> > > > > are alive. It only queries offsets for consumer groups that are
> > > currently
> > > > > connecting to brokers
> > > > >
> > > > > On Fri, 19 Feb 2016 at 13:35 Amoxicillin <shee...@gmail.com>
> wrote:
> > > > >
> > > > > > Hi,
> > > > > >
> > > > > > I use  kafka.tools.ConsumerOffsetChecker to view the consumer
> > offset
> > > > > > status, and can get the correct output, along with a
> > > > > > warning: ConsumerOffsetChecker is deprecated and will be dropped
> in
> > > > > > releases following 0.9.0. Use ConsumerGroupCommand instead.
> > > > > >
> > > > > > But when I altered to bin/kafka-run-class.sh
> > > > > > kafka.admin.ConsumerGroupCommand --zookeeper 127.0.0.1:2181
> > --list,
> > > > > there
> > > > > > was nothing to output.
> > > > > >
> > > > > > Did I missed some parameters to run ConsumerGroupCommand? The
> > version
> > > > is
> > > > > > kafka _2.11-0.9.0.0, and any suggestion is appreciated.
> > > > > >
> > > > >
> > > >
> > >
> >
>

Reply via email to