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