- 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