cckellogg commented on a change in pull request #579:
URL: https://github.com/apache/pulsar-client-go/pull/579#discussion_r680008342
##########
File path: pulsar/producer_impl.go
##########
@@ -177,7 +177,14 @@ func (p *producer) internalCreatePartitionsProducers()
error {
if oldProducers != nil {
oldNumPartitions = len(oldProducers)
- if oldNumPartitions == newNumPartitions {
+ if newNumPartitions < oldNumPartitions {
Review comment:
I didn't think it was possible for the number of partitions to decrease.
What the topic deleted or did the broker return the wrong number of partitions?
Any logs on the broker side to indicate that? If this is ignored will the next
check fix it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
