code: func (p *Plugin) NewAsyncPublisher(connectionName string, topic string, successClb func(messaging.ProtoMessage), errorClb func(messaging.ProtoMessageErr)) (messaging.ProtoPublisher, error) {
  	return p.NewProtoConnection(connectionName).NewAsyncPublisher(topic, successClb, errorClb)
  }
docs: // NewAsyncPublisher creates a publisher that allows to publish messages using asynchronous API. The publisher creates
  // new proto connection on multiplexer with default partitioner.