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
ErrOutOfBrokerswrap 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
- consumer-group: do not cancel sessions context during rebalance by @niamster in #2193
- Revert "consumer-group: do not cancel sessions context during rebalance" by @niamster in #2201
- 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
🔧 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