2017-07-06 9 views
0

次のエラーになっ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バージョン= <をサポートする別のパッケージを提案する可能性があります。

答えて

0

いいえ、自分でパッチしない限り、kafka-pythonでこれを行う方法はありません。代わりに、python 2.7の新しいバージョンにアップグレードすることを強くお勧めします。これはPython 2.7のバージョンがかなり古く、複数のセキュリティ上の脆弱性が存在する可能性があります(SSLを使用しようとしている場合は問題ありません)。

関連する問題