Add property options for kafka sink

[sumerion]

Hi,

Could it be possible to add property options for the kafka sink? In my use case, I'd like to send data to a confluent cloud cluster. For that, I need to add these properties:

security.protocol=SASL_SSL
sasl.mechanisms=PLAIN
sasl.username={{ CLUSTER_API_KEY }}
sasl.password={{ CLUSTER_API_SECRET }}

I tried to add it myself, but I couldn't find how to do it in the current kafka library. My research led me to the https://github.com/fede1024/rust-rdkafka library, which is asynchronous and leads to more code changes. So hoping you know an easier way.

Many thanks