How to sink to kafka in flux engine?

Hi @tfnick ,
So we have recently added the experimental mqtt.to() function in Flux. We plan to add more IoT based protocols in the future. I will make sure to flag Kafka with product management. In the meantime what you could use to achieve your ends is http.post(). You could then use the http_v2 input plugin via Telegraf. If this sounds good we can work on an example together.