Hi, xiangying,
Thanks for your PIP.
IIUC, this may change the existing behavior and may introduce inconsistencies.
Suppose that we have a large message with 3 chunks. But the producer
crashes and resends the message after sending the chunk-1. It will
send a total of 5 messages to the Pulsar topic
Hi Mattison
> but anyway. IMO, it's better to split the
> implementation PR into multiple that
> will help the reviewer review this
> PR more easily.
Good suggestion.
After removing tests, the amount of code lines should be very little.
Mainly changes in the class `ProducerHandler`.
> IMO, it's
> How long will it take to collect sufficient broker load data and bundle
load data?
It would be normally bounded by
`loadBalancerReportUpdateMinIntervalMillis,` but in the worst case,
`loadBalancerReportUpdateMaxIntervalMinutes`.
> And the new leader might only know the new owner of that topic?