pulsar-flink icon indicating copy to clipboard operation
pulsar-flink copied to clipboard

Published 20 hours ago • verified publisher icon streamnative

fix incorrect method getUseEarliestWhenDataLossAndRemoveKey

Open gaozhangmin opened this issue 3 years ago • 1 comments

pulsar.reader.use-earliest-when-data-loss property has been transformed into useEarliestWhenDataLoss by method getPulsarProperties in readerConf.

So methdo getUseEarliestWhenDataLossAndRemoveKey should get useEarliestWhenDataLoss from readerConf instead of use-earliest-when-data-loss.

gaozhangmin avatar Nov 30 '21 08:11 gaozhangmin

@syhily Could you also take a look?

nlu90 avatar Dec 01 '21 01:12 nlu90