kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: OffSet checker.
Date Wed, 18 May 2016 14:13:26 GMT
On Wed, May 18, 2016 at 7:12 AM, Gerard Klijs <gerard.klijs@dizzit.com>
wrote:

> I was just trying to do the same thing, but it does not seem to support ssl
> (or at least not in combination with the acl). I get similar errors as in
> https://issues.apache.org/jira/browse/KAFKA-3151 but when I used
> --command-config /home/kafka/consumer.properties to give the ssl properties
> it worked. It does only seem to work as long as there are client
> connections active.
>
>
Right, if there are no consumers part of the group still active, it
eliminates the group after a timeout period


> This was my output:
> kafka@2b28607f562f:/usr/bin$ ./kafka-consumer-groups --new-consumer
> --group
> mirrormaker --bootstrap-server 192.168.99.100:9093 --describe
> --command-config /home/kafka/consumer.properties
> GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER
> mirrormaker, local.payments.accountentry, 0, 26583507, 26583507, 0,
> mirrormaker-0_172.17.0.1/172.17.0.1
> mirrormaker, local.beb.time, 0, unknown, 0, unknown,
> mirrormaker-0_172.17.0.1/172.17.0.1
> mirrormaker, local.distribution.alert, 0, unknown, 0, unknown,
> mirrormaker-0_172.17.0.1/172.17.0.1
> mirrormaker, local.general.example, 0, unknown, 0, unknown,
> mirrormaker-0_172.17.0.1/172.17.0.1
>
> On Wed, May 18, 2016 at 2:36 PM Christian Posta <christian.posta@gmail.com
> >
> wrote:
>
> > Maybe give it a try with the kafka-consumer-groups.sh tool and the
> > --new-consumer flag:
> >
> >
> >
> > On Wed, May 18, 2016 at 3:40 AM, Sathyakumar Seshachalam <
> > Sathyakumar_Seshachalam@trimble.com> wrote:
> >
> > > The command line tool that comes with Kafka one seems to check offsets
> in
> > > zookeeper. This does not seem to be related to this issue<
> > > https://issues.apache.org/jira/browse/KAFKA-1951> - As I am sure the
> > > offsets are stored in Kafka for burrow seem to retrieve it properly.
> > > Is there any easier way to check the current offset for a given
> consumer
> > > group in Kafka – considering that different consumers within the group
> > > commit to either kafka or Zk ?
> > >
> > > Regards
> > > Sathya,
> > >
> >
> >
> >
> > --
> > *Christian Posta*
> > twitter: @christianposta
> > http://www.christianposta.com/blog
> > http://fabric8.io
> >
>



-- 
*Christian Posta*
twitter: @christianposta
http://www.christianposta.com/blog
http://fabric8.io

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message