を使用してsslでkafkaに接続しようとするとkafka-python
次のエラーが表示されます。
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'
I have python v2.7.3
running on (Debian 7 wheezy)
ssl.SSLContex
属性が追加されましたpython v2.7.9
sslサポートはkafka-python
v1.1.0から導入されたようですが、使用上、pythonバージョン>= v2.7.9が必要ssl.SSLContext
です。
下位バージョンの python を使用して ssl との接続を開始する方法はありkafka-python
ますか?
またはどういうわけかこれをバイパスしますか?
おそらく誰かが、kafka への ssl 接続をサポートし、python バージョン =< 2.7.3 をサポートする別のパッケージを提案できます。