streamnative/pulsar-beat-output

[bug report] BatchingMaxPublishDelay conf init error

holmes07 opened this issue · 1 comments

file : config.go

happens at

if config.BatchingMaxPublishDelay > 0 {
producerOptions.BatchingMaxPublishDelay = config.BatchingMaxPublishDelay * time.Second
}

desc

The delay time will amplification 1000000000 ,Timer Will not execute as expected

solution

remove code * time.Millisecond

if config.BatchingMaxPublishDelay > 0 {
producerOptions.BatchingMaxPublishDelay = config.BatchingMaxPublishDelay
}

close due to #35