In the Zookeeper client, how do I look for an offset for an id / topic group?

We use Kafka 2.10 and zookeeper 3.4. Following the information at http://kafka.apache.org/08/documentation.html#distributionimpl , I try to find the offset for the id group, section section, but find the offset should be empty: ls / consumer / test6 / offsets / ViewerLogs / 0 ---> returns []

Any suggestion on how to access this value?

thank

+4
source share
2 answers

To get the offset value, run the command get / customers / test6 / offsets / ViewerLogs / 0 in zookeeper

+3
source

Take a look at this document:

https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper

, Zookeeper :

/[clusterBasePath]/consumer/[groupId]//[]/[partitionId] → long (offset)

znode , , ( ).

, :

/[clusterBasePath]/consumer/[groupId]/owner/[topic]/[partitionId] → string (consumerId)

, , - -. rebalance.max.retries 50 ( ) rebalance.backoff.ms 5000. - Zookeeper .

, ( ?), , Zookeeper ( , ). Zookeeper .

+1

Source: https://habr.com/ru/post/1570496/


All Articles