code: func (p *Partition) Leader() (int32, error) {
  	if state, err := p.state(); err != nil {
  		return -1, err
  	} else {
  		return state.Leader, nil
  	}
  }
docs: // Leader returns the broker ID of the broker that is currently the leader for the partition.