What's Changed

• fix Kafka::TransactionManager#send_offsets_to_txn by @stasCF in #866
• Add kafka 2.6.0 to Circle CI by @methodmissing in #869
• Resolve "Passing the keyword argument as ..." deprecation warning by @abicky in #875
• Resolve RSpec::Mocks::OutsideOfExampleError by @abicky in #874
• Make "consuming messages with a custom assignment strategy" stable by @abicky in #876
• kafka 2.7.0 by @vvuibert in #880
• Add murmur2_random support for message partitioning. by @divo in #884
• Support seed brokers' hostname with multiple addresses by @abicky in #877
• Fix "@param tag has unknown parameter name" by @abicky in #897
• Updated to ignore all control batches by @rkruze in #893
• Handle SyncGroup responses with a non-zero error and no assignments by @BrentWheeldon in #896
• Refresh metadata if necessary on deliver_message by @wamaral in #901
• ISSUE-525 / 764: ruby-kafka does not support different topic subscriptions in the same consumer group by @eduardopoleoflipp in #903
• Make ssl_ca_cert_file_path support an array of files by @syedriko in #905
• This spec stopped working at some point by @dasch in #909
• Fix multiple [Producer name] tags on failures by @ojab in #910

New Contributors

• @stasCF made their first contribution in #866
• @methodmissing made their first contribution in #869
• @divo made their first contribution in #884
• @rkruze made their first contribution in #893
• @BrentWheeldon made their first contribution in #896
• @wamaral made their first contribution in #901
• @eduardopoleoflipp made their first contribution in #903
• @syedriko made their first contribution in #905
• @ojab made their first contribution in #910

Full Changelog: v1.3.0...v1.4.0

What's Changed

• Various AsyncProducer improvements by @cstyles in #855
• Log RebalanceInProgress in ConsumerGroup#heartbeat as warning by @marcoroth in #858
• change parameter to ssl_verify_hostname in readme by @contrun in #856
• Support custom assignment strategy by @abicky in #846
• Positional and keyword argument handling in Ruby 2.7 by @tsrivishnu in #859
• Improved Exceptions in TransactionManager by @jwilger in #862

New Contributors

• @cstyles made their first contribution in #855
• @marcoroth made their first contribution in #858
• @contrun made their first contribution in #856
• @tsrivishnu made their first contribution in #859

Full Changelog: v1.2.0...v1.3.0

What's Changed

• Instrument create_time from last message in batch by @jonmagic in #811
• Add client function for fetching topic replica count by @lairen in #822
• [Feat] Allow consumers to refresh the topic lists by @lmduc in #818
• Disconnect after leaving the group by @abicky in #817
• Issue 823 > Use max_wait_time while sleeping in fetch_batches by @ElenaHenderson in #825
• Add kafka 2.5 to CI by @geoff2k in #830
• Make verify_hostname settable for ssl contexts by @lairen in #828
• Support Unix domain socket in Kafka::Datadog by @abicky in #827
• Critical bug fix: Extra sanity checking when marking offsets as processed by @theturtle32 in #824
• Use the standard SPDX ID for license in gemspec by @kenhys in #832
• Add some hardening by @dasch in #833

New Contributors

• @lairen made their first contribution in #822
• @lmduc made their first contribution in #818
• @ElenaHenderson made their first contribution in #825
• @geoff2k made their first contribution in #830
• @kenhys made their first contribution in #832

Full Changelog: v1.0.0...v1.1.0

• Add support for config entries in the topic creation API (#540).
• Don't fail on retry when the cluster is secured (#545).

• Add support for the topic deletion API (#528).
• Add support for the partition creation API (#533).
• Allow passing in the seed brokers in a positional argument (#538).

• Instrument the start of message/batch processing (#496).
• Mark Client#fetch_messages as stable.
• Fix the list topics API (#508).
• Add support for LZ4 compression (#499).
• Refactor compression codec lookup (#509).
• Fix compressed message set offset bug (#506).
• Test against multiple versions of Kafka.
• Fix double-processing of messages after a consumer exception (#518).
• Track consumer offsets in Datadog.

Requires Kafka 0.10.1+ due to usage of a few new APIs.

• Fix bug when using compression (#458).
• Update the v3 of the Fetch API, allowing a per-request max_bytes setting (#468).
• Make #deliver_message more resilient using retries and backoff.
• Add support for SASL SCRAM authentication (#465).
• Refactor and simplify SASL code.
• Fix issue when a consumer resets a partition to its default offset.
• Allow specifying a create time for messages (#481).