- Based on librdkafka v1.3.0
- Add new configs
isolation_level
andplugin_library_paths
- Set message_timeout_ms to 0
- Implemented exponential backoff retry policy on consumer
- Fix hex package
- Add zstd into the deps list
- Remove deprecated config
produce.offset.report
- Based on librdkafka v1.0.1
- Removed configs:
queuing_strategy
,offset_store_method
,reconnect_backoff_jitter_ms
- Added new configs:
reconnect_backoff_ms
,reconnect_backoff_max_ms
,max_poll_interval_ms
,enable_idempotence
,enable_gapless_guarantee
get_stats
decodes json to maps instead of proplists
- Fixed memory leaks on the consumer
- Fixed a segmentation fault caused when init handler is throwing exception on consumer
- Refactoring the entire consumer part
- Add support for headers (requires broker version 0.11.0.0 or later)
- Code cleanup
- Add support for dispatch_mode topic setting.
- Based on librdkafka v0.11.6
- Add support for Trevis CI
- Remove plists from deps
- Available via HEX
- Fix crash when stopping erlkaf while using consumers
- Update esq dependency
- Add missing app dependency
- Based on librdkafka v0.11.5
- Add support for the new broker configs: ssl_curves_list, ssl_sigalgs_list, ssl_keystore_location, ssl_keystore_password, fetch_max_bytes
- Add support for the new topic configs: queuing_strategy, compression_level, partitioner
- Fix build process on OSX High Sierra
- Upgrade deps to work on OTP 21 (thanks to Tomislav Trajakovic)
- Initial implementation (both producer and consumer) supporting most of the features available in librdkafka.
- Based on librdkafka v0.11.3
- Tested on Mac OSX, Ubuntu 14.04 LTS, Ubuntu 16.04 LTS