請教大家一下Kafka隊列和Kerberos票據的問題。

我在運行一段python代碼的時候，

from kafka import KafkaConsumer, KafkaProducer

import ssl

...

context = ssl.create_default_context()

context.verify_mode = ssl.CERT_REQUIRED

context.load_verify_locations(self.ssl_cafile)

context.load_cert_chain(certfile=self.ssl_certfile, keyfile=self.ssl_keyfile)

context.options &= ssl.OP_NO_TLSv1

context.options &= ssl.OP_NO_TLSv1_1

return KafkaConsumer (self.inbound_topic, group_id=self.group_id, bootstrap_servers=json.loads(self.bootstrap_servers),

auto_offset_reset=self.auto_offset_reset,

security_protocol=self.security_protocol,

sasl_mechanism=self.sasl_mechanism,

ssl_context=context,

api_version=(0,10))

當正常用kinit設定Kerberos時，以上代碼運行良好。但是，一旦我指定了Kerberos的生存周期，比如kinit “-l 15s”，那么15秒之后以上代碼停滯在return KafkaConsumer那里不動。

這個問題對我的project非常重要，因為涉及到多久refresh一次Kerberos的問題。我本來的設想是：在0~14秒之間，所有return KafkaConsumer所需要的參數已經設置好了，print一下self.bootstrap_servers等等也都正常。那么即使第15秒Kerberos失效，所有return KafkaConsumer所需要的參數不該隨之失效。但是，現在看來不是這樣。可是我也說不清為什么……

請問Python模塊KafkaConsumer會被Kerberos的狀態影響嘛？謝謝了先！

總結

以上是生活随笔為你收集整理的python消费kafka逻辑处理导致cpu升高_请教：Python模块KafkaConsumer会被Kerberos的状态影响嘛？...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。