What's Changed

🎉 New Features / Improvements

• KIP-345: support static membership by @aiquestion in https://github.com/Shopify/sarama/pull/2230

🐛 Fixes

• fix: KIP-368 use receiver goroutine to process all sasl v1 responses by @k-wall in https://github.com/Shopify/sarama/pull/2234

🔧 Maintenance

• chore(deps): bump module github.com/pierrec/lz4 to v4 by @dnwe in https://github.com/Shopify/sarama/pull/2231
• chore(deps): bump golang.org/x/net digest to 2e3eb7b by @dnwe in https://github.com/Shopify/sarama/pull/2232

New Contributors

• @aiquestion made their first contribution in https://github.com/Shopify/sarama/pull/2230

Full Changelog: https://github.com/Shopify/sarama/compare/v1.33.0...v1.34.0

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 https://github.com/Shopify/sarama/pull/2131

🎉 New Features / Improvements

• feat(message): add UnmarshalText method to CompressionCodec by @vincentbernat in https://github.com/Shopify/sarama/pull/2172
• KIP-368 : Allow SASL Connections to Periodically Re-Authenticate by @k-wall in https://github.com/Shopify/sarama/pull/2197
• feat: add batched CreateACLs func to ClusterAdmin by @nkostoulas in https://github.com/Shopify/sarama/pull/2191

🐛 Fixes

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

📦 Dependency updates

• chore(deps): bump xdg-go/scram and klauspost/compress by @dnwe in https://github.com/Shopify/sarama/pull/2170

🔧 Maintenance

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

➕ Other Changes

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

New Contributors

• @k-wall made their first contribution in https://github.com/Shopify/sarama/pull/2154
• @pior made their first contribution in https://github.com/Shopify/sarama/pull/2171
• @omris94 made their first contribution in https://github.com/Shopify/sarama/pull/2185
• @vincentbernat made their first contribution in https://github.com/Shopify/sarama/pull/2172
• @niamster made their first contribution in https://github.com/Shopify/sarama/pull/2182
• @ladislavmacoun made their first contribution in https://github.com/Shopify/sarama/pull/2178
• @nkostoulas made their first contribution in https://github.com/Shopify/sarama/pull/2191

Full Changelog: https://github.com/Shopify/sarama/compare/v1.32.0...v1.33.0

⚠️ This release has been superseded by v1.33.0 and should not be used.

• chore: retract v1.32.0 due to #2150 by @dnwe in https://github.com/Shopify/sarama/pull/2199

What's Changed

🐛 Fixes

• Fix deadlock when closing Broker in brokerProducer by @slaunay in https://github.com/Shopify/sarama/pull/2133

📦 Dependency updates

• chore: refresh dependencies to latest by @dnwe in https://github.com/Shopify/sarama/pull/2159

🔧 Maintenance

• fix: rework RebalancingMultiplePartitions test by @dnwe in https://github.com/Shopify/sarama/pull/2130
• fix(test): use Sarama transactional producer by @dnwe in https://github.com/Shopify/sarama/pull/1939
• chore: enable t.Parallel() wherever possible by @dnwe in https://github.com/Shopify/sarama/pull/2138

➕ Other Changes

• chore: restrict to 1 testbinary at once by @dnwe in https://github.com/Shopify/sarama/pull/2145
• chore: restrict to 1 parallel test at once by @dnwe in https://github.com/Shopify/sarama/pull/2146
• Remove myself from codeowners by @bai in https://github.com/Shopify/sarama/pull/2147
• chore: add retractions for known bad versions by @dnwe in https://github.com/Shopify/sarama/pull/2160

Full Changelog: https://github.com/Shopify/sarama/compare/v1.31.1...v1.32.0

What's Changed

🎉 New Features / Improvements

• feat: add method MockApiVersionsResponse.SetApiKeys by @wuhuizuo in https://github.com/Shopify/sarama/pull/2117
• Expose the TLS connection state of a broker connection by @seveas in https://github.com/Shopify/sarama/pull/2051
• feat: add methods to pause/resume consumer's consumption by @raulnegreiros in https://github.com/Shopify/sarama/pull/2005

🐛 Fixes

• fix: ensure heartbeats only stop after cleanup by @dnwe in https://github.com/Shopify/sarama/pull/2110

📦 Dependency updates

• Update klauspost/compress to 0.14 by @bai in https://github.com/Shopify/sarama/pull/2123

🔧 Maintenance

• Fix typo by @mosceo in https://github.com/Shopify/sarama/pull/2113
• Add Kafka 3.1.0 version number by @bai in https://github.com/Shopify/sarama/pull/2119
• fix(test): make it simpler to re-use toxiproxy by @dnwe in https://github.com/Shopify/sarama/pull/2122
• Add Kafka 3.1.0 to CI matrix, migrate to bitnami kafka image by @bai in https://github.com/Shopify/sarama/pull/2124
• Populate missing kafka versions by @bai in https://github.com/Shopify/sarama/pull/2126
• Backport missing changelog entries from 1.28 onwards by @bai in https://github.com/Shopify/sarama/pull/2127

New Contributors

• @wuhuizuo made their first contribution in https://github.com/Shopify/sarama/pull/2117
• @seveas made their first contribution in https://github.com/Shopify/sarama/pull/2051
• @raulnegreiros made their first contribution in https://github.com/Shopify/sarama/pull/2005

Full Changelog: https://github.com/Shopify/sarama/compare/v1.31.0...v1.31.1

What's Changed

🎉 New Features / Improvements

• feat: expose IncrementalAlterConfigs API in admin.go by @fengyinqiao in https://github.com/Shopify/sarama/pull/2088
• feat: allow AsyncProducer to have MaxOpenRequests inflight produce requests per broker by @xujianhai666 in https://github.com/Shopify/sarama/pull/1686
• Support request pipelining in AsyncProducer by @slaunay in https://github.com/Shopify/sarama/pull/2094

🐛 Fixes

• fix(test): add fluent interface for mocks where missing by @grongor in https://github.com/Shopify/sarama/pull/2080
• fix(test): test for ConsumePartition with OffsetOldest by @grongor in https://github.com/Shopify/sarama/pull/2081
• fix: set HWMO during creation of partitionConsumer (fix incorrect HWMO before first fetch) by @grongor in https://github.com/Shopify/sarama/pull/2082
• fix: ignore non-nil but empty error strings in Describe/Alter client quotas responses by @agriffaut in https://github.com/Shopify/sarama/pull/2096
• fix: skip over KIP-482 tagged fields by @dnwe in https://github.com/Shopify/sarama/pull/2107
• fix: clear preferredReadReplica if broker shutdown by @dnwe in https://github.com/Shopify/sarama/pull/2108
• fix(test): correct wrong offsets in mock Consumer by @grongor in https://github.com/Shopify/sarama/pull/2078
• fix: correct bugs in DescribeGroupsResponse by @dnwe in https://github.com/Shopify/sarama/pull/2111

🔧 Maintenance

• chore: bump runtime and test dependencies by @dnwe in https://github.com/Shopify/sarama/pull/2100

📝 Documentation

• docs: refresh README.md for Kafka 3.0.0 by @dnwe in https://github.com/Shopify/sarama/pull/2099

➕ Other Changes

• Fix typo by @mosceo in https://github.com/Shopify/sarama/pull/2084

New Contributors

• @grongor made their first contribution in https://github.com/Shopify/sarama/pull/2080
• @fengyinqiao made their first contribution in https://github.com/Shopify/sarama/pull/2088
• @xujianhai666 made their first contribution in https://github.com/Shopify/sarama/pull/1686
• @mosceo made their first contribution in https://github.com/Shopify/sarama/pull/2084

Full Changelog: https://github.com/Shopify/sarama/compare/v1.30.1...v1.31.0

What's Changed

🎉 New Features / Improvements

• feat(zstd): pass level param through to compress/zstd encoder by @lizthegrey in https://github.com/Shopify/sarama/pull/2045

🐛 Fixes

• fix: set min-go-version to 1.16 by @troyanov in https://github.com/Shopify/sarama/pull/2048
• logger: fix debug logs' formatting directives by @utrack in https://github.com/Shopify/sarama/pull/2054
• fix: stuck on the batch with zero records length by @pachmu in https://github.com/Shopify/sarama/pull/2057
• fix: only update preferredReadReplica if valid by @dnwe in https://github.com/Shopify/sarama/pull/2076

🔧 Maintenance

• chore: add release notes configuration by @dnwe in https://github.com/Shopify/sarama/pull/2046
• chore: confluent platform version bump by @lizthegrey in https://github.com/Shopify/sarama/pull/2070

Notes

• ℹ️ from Sarama 1.30.x onward the minimum version of Go toolchain required is 1.16.x

New Contributors

• @troyanov made their first contribution in https://github.com/Shopify/sarama/pull/2048
• @lizthegrey made their first contribution in https://github.com/Shopify/sarama/pull/2045
• @utrack made their first contribution in https://github.com/Shopify/sarama/pull/2054
• @pachmu made their first contribution in https://github.com/Shopify/sarama/pull/2057

Full Changelog: https://github.com/Shopify/sarama/compare/v1.30.0...v1.30.1

⚠️ This release has been superseded by v1.30.1 and should not be used.

regression: enabling rackawareness causes severe throughput drops (#2071) — fixed in v1.30.1 via #2076

ℹ️ Note: from Sarama 1.30.0 the minimum version of Go toolchain required is 1.16.x

New Features / Improvements

• #1983 - @zifengyu - allow configure AllowAutoTopicCreation argument in metadata refresh
• #2000 - @matzew - Using xdg-go module for SCRAM
• #2003 - @gdm85 - feat: add counter metrics for consumer group join/sync and their failures
• #1992 - @zhaomoran - feat: support SaslHandshakeRequest v0 for SCRAM
• #2006 - @faillefer - Add support for DeleteOffsets operation
• #1909 - @agriffaut - KIP-546 Client quota APIs
• #1633 - @aldelucca1 - feat: allow balance strategies to provide initial state
• #1275 - @dnwe - log: add a DebugLogger that proxies to Logger
• #2018 - @dnwe - feat: use DebugLogger reference for goldenpath log
• #2019 - @dnwe - feat: add logging & a metric for producer throttle
• #2023 - @dnwe - feat: add Controller() to ClusterAdmin interface
• #2025 - @dnwe - feat: support ApiVersionsRequest V3 protocol
• #2028 - @dnwe - feat: send ApiVersionsRequest on broker open
• #2034 - @bai - Add support for kafka 3.0.0

Fixes

• #1990 - @doxsch - fix: correctly pass ValidateOnly through to CreatePartitionsRequest
• #1988 - @LubergAlexander - fix: correct WithCustomFallbackPartitioner implementation
• #2001 - @HurSungYun - docs: inform AsyncProducer Close pitfalls
• #1973 - @qiangmzsx - fix: metrics still taking up too much memory when metrics.UseNilMetrics=true
• #2007 - @bai - Add support for Go 1.17
• #2009 - @dnwe - fix: enable nilerr linter and fix iferr checks
• #2010 - @dnwe - chore: enable exportloopref and misspell linters
• #2013 - @faillefer - fix(test): disable encoded response/request check when map contains multiple elements
• #2015 - @bai - Change default branch to main
• #1718 - @crivera-fastly - fix: correct the error handling in client.InitProducerID()
• #1984 - @null-sleep - fix(test): bump confluentPlatformVersion from 6.1.1 to 6.2.0
• #2016 - @dnwe - chore: replace deprecated Go calls
• #2017 - @dnwe - chore: delete legacy vagrant script
• #2020 - @dnwe - fix(test): remove testLogger from TrackLeader test
• #2024 - @dnwe - chore: bump toxiproxy container to v2.1.5
• #2033 - @bai - Update dependencies
• #2031 - @gdm85 - docs: do not mention buffered messages in sync producer Close method
• #2035 - @dnwe - chore: populate the missing kafka versions
• #2038 - @dnwe - feat: add a fuzzing workflow to github actions

New Contributors

• @zifengyu made their first contribution in https://github.com/Shopify/sarama/pull/1983
• @doxsch made their first contribution in https://github.com/Shopify/sarama/pull/1990
• @LubergAlexander made their first contribution in https://github.com/Shopify/sarama/pull/1988
• @HurSungYun made their first contribution in https://github.com/Shopify/sarama/pull/2001
• @gdm85 made their first contribution in https://github.com/Shopify/sarama/pull/2003
• @qiangmzsx made their first contribution in https://github.com/Shopify/sarama/pull/1973
• @zhaomoran made their first contribution in https://github.com/Shopify/sarama/pull/1992
• @faillefer made their first contribution in https://github.com/Shopify/sarama/pull/2006
• @crivera-fastly made their first contribution in https://github.com/Shopify/sarama/pull/1718
• @null-sleep made their first contribution in https://github.com/Shopify/sarama/pull/1984

Full Changelog: https://github.com/Shopify/sarama/compare/v1.29.1...v1.30.0

New Features / Improvements

• #1966 - @ajanikow - KIP-339: Add Incremental Config updates API
• #1964 - @ajanikow - Add DelegationToken ResourceType

Fixes

• #1962 - @hanxiaolin - fix(consumer): call interceptors when MaxProcessingTime expire
• #1971 - @KerryJava - fix kafka-producer-performance throughput panic
• #1968 - @dnwe - chore: bump golang.org/x versions
• #1956 - @joewreschnig - Allow checking the entire ProducerMessage in the mock producers
• #1963 - @dnwe - fix: ensure backoff timer is re-used
• #1949 - @dnwe - fix: explicitly use uint64 for payload length

New Features / Improvements

• #1917 - @arkady-emelyanov - KIP-554: Add Broker-side SCRAM Config API
• #1869 - @wyndhblb - zstd: encode+decode performance improvements
• #1541 - @izolight - add String, (Un)MarshalText for acl types.
• #1921 - @bai - Add support for Kafka 2.8.0

Fixes

• #1936 - @dnwe - fix(consumer): follow preferred broker
• #1933 - @ozzieba - Use gofork for encoding/asn1 to fix ASN errors during Kerberos authentication
• #1929 - @celrenheit - Handle isolation level in Offset(Request|Response) and require stable offset in FetchOffset(Request|Response)
• #1926 - @dnwe - fix: correct initial CodeQL findings
• #1925 - @bai - Test out CodeQL
• #1923 - @bestgopher - Remove redundant switch-case, fix doc typos
• #1922 - @bai - Update go dependencies
• #1898 - @mmaslankaprv - Parsing only known control batches value
• #1887 - @withshubh - Fix: issues affecting code quality

Note that with this release we change RoundRobinBalancer strategy to match Java client behavior. See #1788 for details.

• #1870 - @kvch - Update Kerberos library to latest major
• #1876 - @bai - Update docs, reference pkg.go.dev
• #1846 - @wclaeys - Do not ignore Consumer.Offsets.AutoCommit.Enable config on Close
• #1747 - @XSAM - fix: mock sync producer does not handle the offset while sending messages
• #1863 - @bai - Add support for Kafka 2.7.0 + update lz4 and klauspost/compress dependencies
• #1788 - @kzinglzy - feat[balance_strategy]: announcing a new round robin balance strategy
• #1862 - @bai - Fix CI setenv permissions issues
• #1832 - @ilyakaznacheev - Update Godoc link to pkg.go.dev
• #1822 - @danp - KIP-392: Allow consumers to fetch from closest replica

Improvements

#1750 - @krantideep95 Adds missing mock responses for mocking consumer group

Fixes

#1817 - reverts #1785 - Add private method to Client interface to prevent implementation

Improvements

#1775 - @d1egoaz - Adds a Producer Interceptor example
#1781 - @justin-chen - Refresh brokers given list of seed brokers
#1784 - @justin-chen - Add randomize seed broker method
#1790 - @d1egoaz - remove example binary
#1798 - @bai - Test against Go 1.15
#1785 - @justin-chen - Add private method to Client interface to prevent implementation
#1802 - @uvw - Support Go 1.13 error unwrapping

Fixes

#1791 - @stanislavkozlovski - bump default version to 1.0.0

Improvements

#1466 - @rubenvp8510 - Expose kerberos fast negotiation configuration
#1695 - @KJTsanaktsidis - Use docker-compose to run the functional tests
#1699 - @wclaeys - Consumer group support for manually comitting offsets
#1714 - @bai - Bump Go to version 1.14.3, golangci-lint to 1.27.0
#1726 - @d1egoaz - Include zstd on the functional tests
#1730 - @d1egoaz - KIP-42 Add producer and consumer interceptors
#1738 - @varun06 - fixed variable names that are named same as some std lib package names
#1741 - @varun06 - updated zstd dependency to latest v1.10.10
#1743 - @varun06 - Fixed declaration dependencies and other lint issues in code base
#1763 - @alrs - remove deprecated tls options from test
#1769 - @bai - Add support for Kafka 2.6.0

Fixes

#1697 - @kvch - Use gofork for encoding/asn1 to fix ASN errors during Kerberos authentication
#1744 - @alrs - Fix isBalanced Function Signature

Fixes

• #1701 - @d1egoaz - Set server name only for the current broker
• #1694 - @dnwe - testfix: set KAFKA_HEAP_OPTS for zk and kafka

Fixes

• #1692 - @d1egoaz - Set tls ServerName to fix issue: either ServerName or InsecureSkipVerify must be specified in the tls.Config

⚠️ Known Issues

This release has been marked as not ready for production and may be unstable, please use v1.26.4.

Improvements

• #1560 - @iyacontrol - add sync pool for gzip 1-9
• #1605 - @dnwe - feat: protocol support for V11 fetch w/ rackID
• #1617 - @sladkoff / @dwi-di / @random-dwi - Add support for alter/list partition reassignements APIs
• #1632 - @bai - Add support for Go 1.14
• #1640 - @random-dwi - Feature/fix list partition reassignments
• #1646 - @mimaison - Add DescribeLogDirs to admin client
• #1667 - @bai - Add support for kafka 2.5.0

Fixes

• #1594 - @sladkoff - Sets ConfigEntry.Default flag in addition to the ConfigEntry.Source for Kafka versions > V1_1_0_0
• #1601 - @alrs - fix: remove use of testing.T.FailNow() inside goroutine
• #1602 - @d1egoaz - adds a note about consumer groups Consume method
• #1607 - @darklore - Fix memory leak when Broker.Open and Broker.Close called repeatedly
• #1613 - @wblakecaldwell - Updated "retrying" log message when BackoffFunc implemented
• #1614 - @alrs - produce_response.go: Remove Unused Functions
• #1619 - @alrs - tools/kafka-producer-performance: prune unused flag variables
• #1639 - @agriffaut - Handle errors with no message but error code
• #1643 - @kzinglzy - fix config.net.keepalive
• #1644 - @KJTsanaktsidis - Fix brokers continually allocating new Session IDs
• #1645 - @Stephan14 - Remove broker(s) which no longer exist in metadata
• #1650 - @lavoiesl - Return the response error in heartbeatLoop
• #1661 - @KJTsanaktsidis - Fix "broker received out of order sequence" when brokers die
• #1666 - @KevinJCross - Bugfix: Allow TLS connections to work over socks proxy.

⚠️ This release has been superseded by v1.26.4 and should not be used.

Fetch requests will cause the Kafka broker to continously allocate new Fetch sessions in its cache on every request. Fixed in v1.26.2 via https://github.com/Shopify/sarama/pull/1644

Improvements

• Add requests-in-flight metric (1539)
• Fix misleading example for cluster admin (1595)
• Replace Travis with GitHub Actions, linters housekeeping (1573)
• Allow BalanceStrategy to provide custom assignment data (1592)

Bug Fixes

• Adds back Consumer.Offsets.CommitInterval to fix API (1590)
• Fix error message s/CommitInterval/AutoCommit.Interval (1589)

⚠️ Known Issues

This release has been superceded by v1.26.4 and should not be used.

Fetch requests will cause the Kafka broker to continously allocate new Fetch sessions in its cache on every request. Fixed in v1.26.2 via https://github.com/Shopify/sarama/pull/1644

New Features:

• Enable zstd compression (1574,1582)
• Support headers in tools kafka-console-producer (1549)

Improvements:

• Add SASL AuthIdentity to SASL frames (authzid) (1585).

Bug Fixes:

• Sending messages with ZStd compression enabled fails in multiple ways (1252).
• Use the broker for any admin on BrokerConfig (1571).
• Set DescribeConfigRequest Version field (1576).
• ConsumerGroup flooding logs with client/metadata update req (1578).
• MetadataRequest version in DescribeCluster (1580).
• Fix deadlock in consumer group handleError (1581)
• Fill in the Fetch{Request,Response} protocol (1582).
• Retry topic request on ControllerNotAvailable (1586).

⚠️ This release still contained known issues introduced in v1.24.1 and should not be used

Recommended to upgrade to v1.26.4 or rollback to v1.24.0

Known Issues

• ConsumerGroup flooding logs with client/metadata update req (1544) introduced in v1.24.1
• Unexpected user-specified time limit error (1562) introduced in v1.24.1

New Features:

• Support TLS protocol in kafka-producer-performance (1538).
• Add support for kafka 2.4.0 (1552).

Improvements:

• Allow the Consumer to disable auto-commit offsets (1164).
• Produce records with consistent timestamps (1455).

Bug Fixes:

• Fix incorrect SetTopicMetadata name mentions (1534).
• Fix client.tryRefreshMetadata Println (1535).
• Fix panic on calling updateMetadata on closed client (1531).
• Fix possible faulty metrics in TestFuncProducing (1545).

⚠️ This release introduced two new major regressions over v1.24.0 and should not be used

Known Issues

• ConsumerGroup flooding logs with client/metadata update req (1544)
• Unexpected user-specified time limit error (1562)

New Features:

• Add DescribeLogDirs Request/Response pair (1520).

Bug Fixes:

• Fix ClusterAdmin returning invalid controller ID on DescribeCluster (1518).
• Fix issue with consumergroup not rebalancing when new partition is added (1525).
• Ensure consistent use of read/write deadlines (1529).