What's Changed
- use franz-go in kafka plugin by @DmitryRomanov in #646
- add some options for input kafka (heartbeat, session, AWS_MSK_IAM sasl mechanism, auto_commit_interval, balancer algorithm, max_concurrent_fetches,fetch_max_bytes, fetch_min_bytes)
- add some options for output kafka (compression,ack)
Full Changelog: v0.28.0...v0.29.0