code: func (conn *ProtoConnectionFields) StopConsumingPartition(topic string, partition int32, offset int64) error {
  	return conn.multiplexer.stopConsumingPartition(topic, partition, offset, conn.name)
  }
docs: // StopConsumingPartition cancels the previously created subscription for consuming the topic, partition and offset