Version 1.33.0 (2022-05-11)

What's Changed

🚨 Breaking Changes

Note: with this change, the user of Sarama is required to use Go 1.13's errors.Is etc (rather then ==) when forming conditionals returned by this library.

• feat: make ErrOutOfBrokers wrap the underlying error that prevented connections to the brokers by @k-wall in #2131

🎉 New Features / Improvements

• feat(message): add UnmarshalText method to CompressionCodec by @vincentbernat in #2172
• KIP-368 : Allow SASL Connections to Periodically Re-Authenticate by @k-wall in #2197
• feat: add batched CreateACLs func to ClusterAdmin by @nkostoulas in #2191

🐛 Fixes

• fix: TestRecordBatchDecoding failing sporadically by @k-wall in #2154
• feat(test): add an fvt for broker deadlock by @dnwe in #2144
• fix: avoid starvation in subscriptionManager by @dnwe in #2109
• fix: remove "Is your cluster reachable?" from msg by @dnwe in #2165
• fix: remove trailing fullstop from error strings by @dnwe in #2166
• fix: return underlying sasl error message by @dnwe in #2164
• fix: potential data race on a global variable by @pior in #2171
• fix: AdminClient | CreateACLs | check for error in response, return error if needed by @omris94 in #2185
• producer: ensure that the management message (fin) is never "leaked" by @niamster in #2182
• fix: prevent RefreshBrokers leaking old brokers by @k-wall in #2203
• fix: prevent RefreshController leaking controller by @k-wall in #2204
• fix: prevent AsyncProducer retryBatch from leaking by @k-wall in #2208
• fix: prevent metrics leak when authenticate fails by @Stephan14 in #2205
• fix: prevent deadlock between subscription manager and consumer goroutines by @niamster in #2194
• fix: prevent idempotent producer epoch exhaustion by @ladislavmacoun in #2178
• fix(test): mockbroker offsetResponse vers behavior by @dnwe in #2213
• fix: cope with OffsetsLoadInProgress on Join+Sync by @dnwe in #2214
• fix: make default MaxWaitTime 500ms by @dnwe in #2227

📦 Dependency updates

• chore(deps): bump xdg-go/scram and klauspost/compress by @dnwe in #2170

🔧 Maintenance

• fix(test): skip TestReadOnlyAndAllCommittedMessages by @dnwe in #2161
• fix(test): remove t.Parallel() by @dnwe in #2162
• chore(ci): bump along to Go 1.17+1.18 and bump golangci-lint by @dnwe in #2183
• chore: switch to multi-arch compatible docker images by @dnwe in #2210

➕ Other Changes

• Remediate a number go-routine leaks (mainly test issues) by @k-wall in #2198
• chore: retract v1.32.0 due to #2150 by @dnwe in #2199
• chore: bump functional test timeout to 12m by @dnwe in #2200
• fix(admin): make DeleteRecords err consistent by @dnwe in #2226

New Contributors

• @k-wall made their first contribution in #2154
• @pior made their first contribution in #2171
• @omris94 made their first contribution in #2185
• @vincentbernat made their first contribution in #2172
• @niamster made their first contribution in #2182
• @ladislavmacoun made their first contribution in #2178
• @nkostoulas made their first contribution in #2191

Full Changelog: v1.32.0...v1.33.0