0

を使用して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.3running on (Debian 7 wheezy)
ssl.SSLContex属性が追加されましたpython v2.7.9

sslサポートはkafka-pythonv1.1.0から導入されたようですが、使用上、pythonバージョン>= v2.7.9が必要ssl.SSLContextです。

下位バージョンの python を使用して ssl との接続を開始する方法はありkafka-pythonますか?
またはどういうわけかこれをバイパスしますか?

おそらく誰かが、kafka への ssl 接続をサポートし、python バージョン =< 2.7.3 をサポートする別のパッケージを提案できます。

4

1 に答える 1