tree afbb03b8a58ed5501e4b0d560e5a831a02b664ca
parent 9cbb1d1d855dbbcbc54eb02a11ade9e6b5717e4a
author Zike Yang <ar@armail.top> 1624304026 +0800
committer GitHub <noreply@github.com> 1624304026 +0200
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJg0OmbCRBK7hj4Ov3rIwAAt+cIAAFXgzVXw4uJAuFh9Za4bfx9
 sfyDXgHA8GwI3aJsW+ILYBJL2bsJSSogs9iyb+b4rWrlEOZ06R4Fw5nsd29cZ81p
 MJ+qv/6XiGFdmN4qTLCFr7q7+TTK5fhM+Wpf6osHZaAMiLLdW5DrnuSe4E4Qh3+O
 mge+GQB5JqebaJBDea8zOO7LZEtRoyPLmqyOjgRnoN+GET5yC4G0G5af8Fs10kOR
 Gx49j0oMdf3KNUnjCkaxG5xKIMEFAnq2oLHt6T32qU1kIvqYCO/UvdBiteJy+IiQ
 4/4ig2frw98S1f9K4mUYkzHTXNVMynV188hpSZ+3wlTzccj8RBP1QDlSVvCJTLQ=
 =XoWn
 -----END PGP SIGNATURE-----
 

Basic partitioned producer (#71)

* Add GetPartitions.

* Add PartitionedProducerProcess.

* Add PartitionedProducerProcess Test.

* Remove PartitionedProducerState.

* Add UpdatePartitions Event.

* Implement PartitionedProducer.

* Refactor CreateProducer

* Fix sub topic format error

* Fix some problems

* Remove PartitionedProducerProcess.

* Make some classes sealed.

* Use await in PartitionedProducer.Send

* Make PulsarClient internal and fix tests.

* Make GetNumberOfPartitions private.

* Fix test method name.

* Use NSubstitute instead of Moq.

* Make CreateSubProducers sync.

* Fix some comments.

* Fix warnings

* Subproducers

* Update

* Change PartitionedProducer to Producer and add some comments.

* Add UpdatePartitions to connect logic and fix some other problems.

* Update Partitions when start process.

* Fix test warnings.