v3.135.0
·
113 commits
to master
since this release
- Added
topicoptions.WithWriterErrOnQueueFull(bool)option for topic writer to makeWritereturntopicwriter.ErrQueueLimitExceedimmediately when the internal queue is full, instead of blocking. Useful for preventing OOM when the writer cannot keep up with produced messages. - Un-deprecated
topicwriter.ErrQueueLimitExceed: it is returned byWritewhen a writer is created withtopicoptions.WithWriterErrOnQueueFull(true)and the internal queue is full.
Full Changelog: v3.134.2...v3.135.0