code: func (p *Plugin) NewBytesConnectionToPartition(name string) *mux.BytesManualConnectionStr {
  	return p.mux.NewBytesManualConnection(name)
  }
docs: // NewBytesConnectionToPartition returns a new instance of a connection to access kafka brokers. The connection allows to create
  // new kafka providers/consumers on multiplexer with manual partitioner which allows to send messages to specific partition
  // in kafka cluster and watch on partition/offset.