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