Hi!
I’m trying to setup Scala stream collector to connect to Kafka brokers that requires JASS configuration setup.
e.g:
ssl.endpoint.identification.algorithm=https
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=“" password="**”;
How can I add these configurations to Snowplow collector(and enricher)? config.hocon doesn’t seem to take these settings and I can’t find any reference or documentation for this.
How can I setup snowplow collectors and enricher to connect to Kafka brokers that requires client authentication via SASL?
Thanks,