- Changed: config defaults to be aligned with Kafka client defaults #30
- updated kafka client (and its dependencies) to version 2.4.1 (#16)
- 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
- Refactor : made
partition_assignment_strategy
option easier to configure by accepting simple values from an enumerated set instead of requiring lengthy class paths (#25)
- 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: