From 0cd412f8a1129803095211c4f639a8a64bfbb14a Mon Sep 17 00:00:00 2001 From: WeizhongTu Date: Wed, 16 Apr 2025 11:04:16 +0800 Subject: [PATCH] chore: remove consumer.WithRetry(unnecessary option to prevent misuse) --- consumer/option.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/consumer/option.go b/consumer/option.go index 608917d5..b86803c4 100644 --- a/consumer/option.go +++ b/consumer/option.go @@ -258,14 +258,6 @@ func WithVIPChannel(enable bool) Option { } } -// WithRetry return a Option that specifies the retry times when send failed. -// TODO: use retry middleware instead -func WithRetry(retries int) Option { - return func(opts *consumerOptions) { - opts.RetryTimes = retries - } -} - func WithCredentials(c primitive.Credentials) Option { return func(options *consumerOptions) { options.ClientOptions.Credentials = c