- Update brod dependency to ~> 3.6 or ~> 4.0
- Support setting socket options on Kafka connection
- Add support for timestamp
:offset_reset_policy
- Supports reading sasl credentials from file
- Add
:begin_offset
option - Do not block until coordinator exits to avoid deadlocks
- Disable
offset_commit_on_ack
during revoke assignment call
- Implement fairer distribution of messages across partitions
- Add :request_timeout option to BrodClient
- Send telemetry when assignments_revoked is executed
- Do not poll while draining
- Properly shutdown Brod's group coordinators
- Support
:rebalance_timeout_seconds
option - Support
:query_api_versions
option
- Do not send more messages per partition than
max_demand
- Support for custom
:sasl
authenticators by allowing :callback to be sent as opts
- Pass SSL configurations when validating offset
- Ensure
handle_info
does not crash when receiving an EXIT message in case Kafka goes offline
- Ensure reset_policy is only used when offset is
undefined
orout_of_range
- Allow
:sasl
option to be set to:undefined
- Allow
:heartbeat_rate_seconds
option to group config - Handle
:offset_out_of_range
errors when resolving offset - Ensure
brod
processes terminate on disconnections
- Support
:client_id_prefix
to make it easier to identify Kafka connections - Add support for
:max_wait_time
in fetch - Require Broadway 1.0
- Add an API for updating topics on producers
- Support consuming compacted topics
- Relax Brod dependency
- Fix resetting offset on every assignment
- Add support for single string hosts configuration
- Add support for tuple lists with string as key in hosts
- Drop invalid support of topic/partition for topics option
- Add SASL authentication support
- Allow boolean for client config ssl option
- Append
headers
to message metadata
- Initial release