AsyncProducer.Close() waits for Flush.Frequency #2805
Labels
needs-investigation
Issues that require followup from maintainers
stale
Issues and pull requests without any recent activity
Description
Does Sarama
AsyncProducer.Close()
wait for up to the duration ofFlush.Frequency
before performing a flush? I expected the.Close()
to just close the channels and just flush as fast as possible, as there will be no future messages.I did small experiments with my setup, and also looked at
async_producer.go
. Both confirm that it can wait up toFlush.Frequency
before actually flushing.Versions
Configuration
Flush.Frequency
of 30 seconds.Logs
logs: CLICK ME
This was the log when I created a producer, set the frequency to 30s, write some messages, and close the producer afterwards. (see 29s `.Close()` in timestamp)
Additional Context
Wondering if this is the expected behavior or a bug.
The text was updated successfully, but these errors were encountered: