如何解决 Kafka-Python SSL UNEXPECTED_MESSAGE

编程问答 2022-05-28

问题描述

在尝试使用 kafka-python 连接 KafaProducer 时，如何解决此 SSL 错误消息？我知道网络良好并且密钥库工作正常，因为我可以通过 KaDeck 成功连接到此服务器和主题。


def connect_kafka_producer():
    _producer = None
    try:
        _bootstrap = 'b-3.fakedns.kafka.us-east-1.amazonaws.com:9094'
        _producer = KafkaProducer(bootstrap_servers=[_bootstrap],request_timeout_ms=5000,max_block_ms=5000,security_protocol="SSL",ssl_keyfile="C:\fakepath\mykeyname.keystore",ssl_password="fakepassword")
    except Exception as ex:
        print('Exception while connecting Kafka')
        print(str(ex))
    finally:
        return _producer

[SSL: UNEXPECTED_MESSAGE] unexpected message (_ssl.c:1123)

这就是我从 DEBUG 日志输出中得到的全部。

DEBUG:kafka.metrics.metrics:Added sensor with name connections-closed
DEBUG:kafka.metrics.metrics:Added sensor with name connections-created
DEBUG:kafka.metrics.metrics:Added sensor with name select-time
DEBUG:kafka.metrics.metrics:Added sensor with name io-time
DEBUG:kafka.client:Initiating connection to node bootstrap-0 at b-3.fakedns.kafka.us-east-1.amazonaws.com:9094
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent-received
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name request-latency
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap-0.bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap-0.bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap-0.latency
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <disconnected> [unspecified None]>: creating new socket
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <disconnected> [IPv4 ('10.999.999.999',9094)]>: setting socket option (6,1,1)
INFO:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <connecting> [IPv4 ('10.999.999.999',9094)]>: connecting to b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 [('10.999.999.999',9094) IPv4]
INFO:kafka.conn:Probing node bootstrap-0 broker version
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <connecting> [IPv4 ('10.999.999.999',9094)]>: established TCP connection
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <connecting> [IPv4 ('10.999.999.999',9094)]>: initiating SSL handshake
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <handshake> [IPv4 ('10.999.999.999',9094)]>: configuring default SSL Context
INFO:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <handshake> [IPv4 ('10.999.999.999',9094)]>: Loading system default SSL CAs from DefaultVerifyPaths(cafile=None,capath=None,openssl_cafile_env='SSL_CERT_FILE',openssl_cafile='C:\\Program Files\\Common Files\\ssl/cert.pem',openssl_capath_env='SSL_CERT_DIR',openssl_capath='C:\\Program Files\\Common Files\\ssl/certs')
DEBUG:kafka.conn:<brokerConnection node_id=bootstrap-0 host=b-3.fakedns.kafka.us-east-1.amazonaws.com:9094 <handshake> [IPv4 ('10.999.999.999',9094)]>: wrapping socket in ssl context

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

amazon-mskkafka-pythonssl