Hello, I'm looking for some info on how to connect to my Kafka instance hosted on Aiven behind TLS/SSL

it doesn't look as though this is supported by Onyx/onyx-kafka, is that correct?

@theblackbox I do not believe security is implemented

thanks for the heads up, I'll delve into their git and see when it might be

@theblackbox You can pass arbitrary opts to the producer and consumer connections.

hero, is that fed through props.put or some such then?

:kafka/consumer-opts

beat me

yes!

also :kafka/producer-opts

you guys always amaze, cheers

:thumbsup:

If anyone wants to have a play with it early before we announce tomorrow, we went ahead and made Roaming openly available. Write plain Clojure that operates over distributed streams, test it with Docker, execute it at scale in our cloud. All Onyx under the hood, naturally. 🙂 https://github.com/pyroclastio/pyroclast-clojure#roaming

nice