Hi All,
My kafka cluster is kafka0.10.0.
I have found two reasons for Auto offset commit failed in the log file. One
is Commit cannot be completed since the group has already rebalanced and
assigned the partitions to another member, and another is Commit offsets failed
with retriable exc
offsets have all been expired,
the group registry will be deleted.
Guozhang
On Thu, Aug 11, 2016 at 8:55 PM, yuanjia8...@163.com
wrote:
> Hi all，
> When I use kafka-consumer-groups.sh to delete new-consumer's group,
> the shell note that "Option [delete] is not valid
Hi all，
When I use kafka-consumer-groups.sh to delete new-consumer's group, the
shell note that "Option [delete] is not valid with [new-consumer]. Note that
there's no need to delete group metadata for the new consumer as it is
automatically deleted when the last member leaves."
How to u
et the enable delete config right, and re-try to
see if this issue is re-producible.
Guozhang
On Thu, Jul 21, 2016 at 11:52 PM, yuanjia8...@163.com
wrote:
> Hi Guozhang,
>
> I want to get the latest offset, code as follows:
> consumer.assign(topicPartitionList);
> consumer.se
r position block
Hello Yuanjia,
Could you share your code example on calling consumer.position()? Is the
partition that you are getting the offset from assigned to the consumer?
Guozhang
On Wed, Jul 20, 2016 at 11:50 PM, yuanjia8...@163.com
wrote:
> Hi,
> With kafka-clients
Hi,
With kafka-clients-0.10.0.0, I use KafkaConsumer.position() to get the
offset, the process block in ConsumerNetworkClient.awaitMetadataUpdate. Block
until the meadata has been refreshed.
My questions are:
1. Why the metadata not refresh?
2. Could it use timeout or throw ex
Hi all,
I have the problem that broker id 1 exist in one topic's ISR and is the
only one, but id 1 do not exist in zookeeper path /broker/ids.
Any idea why it's happening? Is it split-brain?
Thanks.
LiYuanJia
Hi Jerry,
1. Make sure that 1000 messages have been sent to kafka, before consuming.
2. If you don't care the sequence between messages, you can use mutiple
partition and use more comsumers.
LiYuanJia
From: Jerry Wong
Date: 2016-02-17 05:33
To: users
Subject: Optimize the performance
