The issue is that the default SSL config is now set to verify_peer with cacerts (or cacertfile) defaulting to undefined, which results in an error (because the value for cacerts must be provided).
A workaround is to configure ssl_options anyway, even when SSL is ostensibly disabled:
Due to the changes to the ssl module to provide safer defaults,
kafka_ex
will fail to connect to a broker even whenuse_ssl
isfalse
.The issue is that the default SSL config is now set to
verify_peer
withcacerts
(orcacertfile
) defaulting toundefined
, which results in an error (because the value forcacerts
must be provided).A workaround is to configure
ssl_options
anyway, even when SSL is ostensibly disabled: