code: func (conn *ProtoManualConnection) NewAsyncPublisherToPartition(topic string, partition int32, successClb func(messaging.ProtoMessage), errorClb func(messaging.ProtoMessageErr)) (messaging.ProtoPublisher, error) {
  	return &protoManualAsyncPublisherKafka{conn, topic, partition, successClb, errorClb}, nil
  }
docs: // NewAsyncPublisherToPartition creates a new instance of protoManualAsyncPublisherKafka that allows to publish sync kafka
  // messages using common messaging API.