code: func (p *Partition) state() (partitionState, error) {
  	var state partitionState
  	node := fmt.Sprintf("%s/brokers/topics/%s/partitions/%d/state", p.topic.kz.conf.Chroot, p.topic.Name, p.ID)
  	value, _, err := p.topic.kz.conn.Get(node)
  	if err != nil {
  		return state, err
  	}
  
  	if err := json.Unmarshal(value, &state); err != nil {
  		return state, err
  	}
  
  	return state, nil
  }
docs: // state retrieves and parses the partition State