Hey folks, I do have question about kafka connector available in Airbyte. Our kafka cluster support SSL, therefore I don't see an option on the connector properties to select the keystore and truststore, any idea how I can get the connector to support SSL? do I have to modify the current connector implementation? thanks! looking forward to get an answer soon.

Hey there is this about source connector (extracting from kafka) or destination (loading into kafka)?

It can be both. Our kafka cluster supports SSL where both consumer and producer topics are configured.

Looks like there is an open issue around this: https://github.com/airbytehq/airbyte/issues/14474 The user found an interesting workaround for the destination connector documented in their linked thread, to get SASL_SSL working they added a

COPY

statement into the connector's dockerfile to add the cert into the java environment's cacerts. I haven't tested this, and i'm not sure if they tried it on the source connector but it may work there too since it's also written in java