[
https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198271#comment-16198271
]
Manikumar commented on KAFKA-6022:
----------------------------------
looks like you are using old consumer API on mirror maker. By default, old
consumer API uses zookeeper for offset storage ( check
offsets.storage=zookeeper config property). If you are on newer versions of
Kafka, then it is advisable to use new consumer on mirror maker.
You can enable new consumer on mirror maker by using "---new.consumer" command
line option
> mirror maker stores offset in zookeeper
> ---------------------------------------
>
> Key: KAFKA-6022
> URL: https://issues.apache.org/jira/browse/KAFKA-6022
> Project: Kafka
> Issue Type: Improvement
> Reporter: Ronald van de Kuil
> Priority: Minor
>
> I happened to notice that the mirror maker stores its offset in zookeeper.
> I do not see it using:
> bin/kafka-consumer-groups.sh --bootstrap-server pi1:9092 --new-consumer --list
> I do however see consumers that store their offset in kafka.
> I would guess that storing the offset in zookeeper is old style?
> Would it be an idea to update the mirror maker to the new consumer style?
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
