Release date 2025/03/27
Added support for sending messages to multiple topics with topics_query_arg, and enabled topic allowlisting with allowed_topics.
Added support for message manipulation with the new configuration field message_by_lua_functions.
Release date 2023/08/09
Fixed an issue where the plugin could lose connection to a broker when the broker leadership changed.
Release date 2022/11/21
Fixed the Bad Gateway error that would occur when using the Kafka Upstream plugin with the configuration producer_async=false.
Release date 2022/03/02
Added the ability to identify a Kafka cluster using the cluster_name configuration parameter. By default, this field generates a random string. You can also set your own custom cluster identifier.
Beta feature: The authentication.user and authentication.password configuration fields are now marked as referenceable, which means they can be securely stored assecretsin a vault. References must follow a specific format.