- updated kafka client (and its dependencies) to version 2.4.1
- added the input
client_rack
parameter to enable support for follower fetching - added the output
partitioner
parameter for tuning partitioning strategy - Refactor: normalized error logging a bit - make sure exception type is logged
- Fix: properly handle empty ssl_endpoint_identification_algorithm #8
- Fix links in changelog pointing to stand-alone plugin changelogs.
- Refactor: scope java_import to plugin class
- Initial release of the Kafka Integration Plugin, which combines previously-separate Kafka plugins and shared dependencies into a single codebase; independent changelogs for previous versions can be found: