Hey all, maybe I'm missing something, but does the...
# troubleshooting
r
Hey all, maybe I'm missing something, but does the RabbitMQ connector have SSL/TLS support? I'm building apps for Kinesis Data Analytics, so I'm currently on v1.13.2, with the option to run v1.15.x, but I don't see an SSL/TLS option exposed on
RMQConnectionConfig.Builder
even in the v1.18 docs. I also don't see the
getConnectionFactory
method looking at the protocol of the URI (if supplied) to enable SSL if the protocol is
amqps
vs
amqp
.
After digging a little deeper in RMQSink, I found that TLS is not enabled by default and that I needed to provide a subclass overriding the
setupConnection()
method.