code: func (p *Plugin) NewProtoConnection(name string) mux.Connection {
  	return p.mux.NewProtoConnection(name, &keyval.SerializerJSON{})
  }
docs: // NewProtoConnection 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.The connection uses proto-modelled messages.