There are mbeans named KafkaCommitsPerSec and ZooKeeperCommitsPerSec -
can you look those up and see what they report?
On Thu, Feb 12, 2015 at 07:32:39PM +0800, tao xiao wrote:
> Hi team,
>
> I was trying to migrate my consumer offset from kafka to zookeeper.
>
> Here is the original settings of my consumer
>
> props.put("offsets.storage", "kafka");
>
> props.put("dual.commit.enabled", "false");
> Here is the steps
>
> 1. set dual.commit.enabled=true
> 2. restart my consumer and monitor offset lag with
> kafka.tools.ConsumerOffsetChecker
> 3. set offsets.storage=zookeeper
> 4. restart my consumer and monitor offset lag with
> kafka.tools.ConsumerOffsetChecker
>
> After step 4 my consumer was able to continually consume data from topic
> but the offset lag remained unchanged. Did I do anything wrong?
>
> --
> Regards,
> Tao
