I am not familiar with sarama. You can use zkcli.sh from zookeeper
distribution and find if anything exists in path /chroot/consumers where
chroot is located in your bootstrap.servers properties if you set it. If
you dont find anything in /consumers offset is most likely managed in
kafka. Then you
I suppose the offset is stored in kafka not in zk, because the newest
sarama's offset manager support it, and it shown a topic named
__consumer_offsets.
Could you please point where is the zk path of /chroot/consumer? I'm a
newbie of zk and kafka.
On Fri, Feb 19, 2016 at 4:11 PM, tao xiao wrote:
I'd assume the offset is managed in zk. then kafka-run-class.sh
kafka.admin.ConsumerGroupCommand --list --zookeeper localhost:2181 should
output the consumer group that is saved in zk. can you check what is stored
in zk path /chroot/consumers?
On Fri, 19 Feb 2016 at 16:06 Amoxicillin wrote:
> I
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 wrote:
> which version of consumer do you use?
>
>
> On Fri, 19 Feb 2016 at 15:26 Amoxicillin wrote:
>
> > I tried as you suggested, but still no output of any
which version of consumer do you use?
On Fri, 19 Feb 2016 at 15:26 Amoxicillin 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 wrote:
>
> > That is what I mean alive. If you use new consumer connecting to broker
> > you s
I tried as you suggested, but still no output of any group info.
On Fri, Feb 19, 2016 at 2:45 PM, tao xiao 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.Consu
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 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 wrote:
> when using ConsumerGroupCommand you need to make sure your consumer groups
> are alive. It only queries of
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 wrote:
> Hi,
>
> I use kafka.tools.ConsumerOffsetChecker to view the consumer offse
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.s
10 matches
Mail list logo
