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