code: func (conn *ProtoManualConnection) WatchPartition(msgClb func(messaging.ProtoMessage), topic string, partition int32, offset int64) error {
  	return conn.ConsumePartition(msgClb, topic, partition, offset)
  }
docs: // WatchPartition is an alias for ConsumePartition method. The alias was added in order to conform to
  // messaging.Mux interface.