code: func (p *Plugin) NewBytesConnection(name string) *mux.BytesConnectionStr {
  	return p.mux.NewBytesConnection(name)
  }
docs: // NewBytesConnection returns a new instance of a connection to access kafka brokers. The connection allows to create
  // new kafka providers/consumers on multiplexer with hash partitioner.