次のエラーになっkafka-python
はカフカ-pythonのSSLサポート<v2.7.9(無属性のSSLContextのない ')
イムを使用してカフカにSSLで接続しよう:私が持っている
Traceback (most recent call last):
File "server.py", line 23, in <module>
kafka_producer = SimpleKafkaProducer()
File "/my-service/kafka_producer.py", line 28, in __init__
self.producer = KafkaProducer(**kafka_config)
File "./ve/lib/python2.7/site-packages/kafka/producer/kafka.py", line 266, in __init__
client = KafkaClient(**self.config)
File "./ve/lib/python2.7/site-packages/kafka/client_async.py", line 130, in __init__
self._bootstrap(collect_hosts(self.config['bootstrap_servers']))
File "./ve/lib/python2.7/site-packages/kafka/client_async.py", line 158, in _bootstrap
bootstrap.connect()
File "./ve/lib/python2.7/site-packages/kafka/conn.py", line 149, in connect
self._wrap_ssl()
File "./ve/lib/python2.7/site-packages/kafka/conn.py", line 207, in _wrap_ssl
self._ssl_context = ssl.SSLContext(ssl.PROTOCOL_SSLv23) # pylint: disable=no-member
AttributeError: 'module' object has no attribute 'SSLContext'
を(Debianの7喘鳴)上で実行されているpython v2.7.3
ssl.SSLContex
属性がpython v2.7.9
から追加されたことはkafka-python
のSSLサポートがイントロだったようですこれは、ssl.SSLContext
のために、バージョン1.01より高いです。 ですが、pythonバージョン> = v2.7.9、 が必要です。
下位バージョンのPythonとkafka-python
を使用してsslとの接続を開始する方法はありますか?
か何かこれを回避しますか?
多分、誰かがkafkaへのssl接続をサポートし、pythonバージョン= <をサポートする別のパッケージを提案する可能性があります。