Zixuan Liu comments

Repositories
Issues
Comments

Results 213 comments of


                                            Zixuan Liu

[fix][broker] Replication stuck when partitions count between two clusters is not the same

When a topic type is different(non-partitioned/partitioned) on the local and remote clusters, the pulsar-client has been thrown `Producer with name 'pulsar.repl.c1--> c2' is already connected to topic tp-1-partition-0/tp-1-partition-1`, I think...

[improve] [pip] PIP-363: Add callback parameters to the method: org.apache.pulsar.client.impl.SendCallback.sendComplete.

ConcurrentModificationException

Default enforce is non-thread-safe, you can switch to SyncedEnforcer, or you add a loading request to the single thread to avoid the concurrent issue.