code: func (t *Topic) WatchPartitions() (PartitionList, <-chan zk.Event, error) {
  	value, _, c, err := t.kz.conn.GetW(t.metadataPath())
  	if err != nil {
  		return nil, nil, err
  	}
  
  	list, err := t.parsePartitions(value)
  	return list, c, err
  }
docs: // WatchPartitions returns a list of all partitions for the topic, and watches the topic for changes.