Version 1.26.2 (2020-05-06)

⚠️ 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.

Version 1.26.1 (2020-02-04)

⚠️ 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 #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)

Version 1.26.0 (2020-01-24)

⚠️ 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 #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).

Version 1.25.0 (2020-01-13)

⚠️ 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).

Version 1.24.1 (2019-10-31)

⚠️ 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).

Version 1.24.0 (2019-10-09)

New Features:

• Add sticky partition assignor (1416).
• Switch from cgo zstd package to pure Go implementation (1477).

Improvements:

• Allow creating ClusterAdmin from client (1415).
• Set KafkaVersion in ListAcls method (1452).
• Set request version in CreateACL ClusterAdmin method (1458).
• Set request version in DeleteACL ClusterAdmin method (1461).
• Handle missed error codes on TopicMetaDataRequest and GroupCoordinatorRequest (1464).
• Remove direct usage of gofork (1465).
• Add support for Go 1.13 (1478).
• Improve behavior of NewMockListAclsResponse (1481).

Bug Fixes:

• Fix race condition in consumergroup example (1434).
• Fix brokerProducer goroutine leak (1442).
• Use released version of lz4 library (1469).
• Set correct version in MockDeleteTopicsResponse (1484).
• Fix CLI help message typo (1494).

Known Issues:

• Please don't use Zstd, as it doesn't work right now. See #1252.

Version 1.23.1 (2019-07-22)

Bug Fixes:

• Fix fetch delete bug record (1425).
• Handle SASL/OAUTHBEARER token rejection (1428).

Version 1.23.0 (2019-07-02)

New Features:

• Add support for Kafka 2.3.0 (1418).
• Add support for ListConsumerGroupOffsets v2 (1374).
• Add support for DeleteConsumerGroup (1417).
• Add support for SASLVersion configuration (1410).
• Add kerberos support (1366).

Improvements:

• Improve sasl_scram_client example (1406).
• Fix shutdown and race-condition in consumer-group example (1404).
• Add support for error codes 77—81 (1397).
• Pool internal objects allocated per message (1385).
• Reduce packet decoder allocations (1373).
• Support timeout when fetching metadata (1359).

Bug Fixes:

• Fix fetch size integer overflow (1376).
• Handle and log throttled FetchResponses (1383).
• Refactor misspelled word Resouce to Resource (1368).

Version 1.22.1 (2019-04-29)

Improvements:

• Use zstd 1.3.8 (1350).
• Add support for SaslHandshakeRequest v1 (1354).

Bug Fixes:

• Fix V5 MetadataRequest nullable topics array (1353).
• Use a different SCRAM client for each broker connection (1349).
• Fix AllowAutoTopicCreation for MetadataRequest greater than v3 (1344).

Version 1.22.0 (2019-04-09)

New Features:

• Add Offline Replicas Operation to Client (1318).
• Allow using proxy when connecting to broker (1326).
• Implement ReadCommitted (1307).
• Add support for Kafka 2.2.0 (1331).
• Add SASL SCRAM-SHA-512 and SCRAM-SHA-256 mechanismes (1331).

Improvements:

• Unregister all broker metrics on broker stop (1232).
• Add SCRAM authentication example (1303).
• Add consumergroup examples (1304).
• Expose consumer batch size metric (1296).
• Add TLS options to console producer and consumer (1300).
• Reduce client close bookkeeping (1297).
• Satisfy error interface in create responses (1154).
• Please lint gods (1346).

Bug Fixes:

• Fix multi consumer group instance crash (1338).
• Update lz4 to latest version (1347).
• Retry ErrNotCoordinatorForConsumer in new consumergroup session (1231).
• Fix cleanup error handler (1332).
• Fix rate condition in PartitionConsumer (1156).