code: func newChannel(topic string, partition int32) channel {
  	return &channelImpl{
  		tpc: fmt.Sprintf("%s", topic),
  		prt: partition,
  	}
  }
docs: // Returns a new channel for a given topic name and partition number.