oura
oura copied to clipboard
Add property options for kafka sink
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