请教大家一下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的状态影响嘛?...相关推荐

  1. python消费kafka逻辑处理导致cpu升高_爬虫架构|利用Kafka处理数据推送问题(1)

    如下图1-1所示,我们之前爬虫集群在采集完数据之后是直接插入到MySQL数据库中,分发服务再消费MySQL里面的数据.这样的设计会有两个主要的问题: 随着数据量越来越大,数据保存和数据存取的响应效率是 ...

  2. python消费kafka逻辑处理导致cpu升高_大数据技术之一次KAFKA消费者异常引起的思考...

    本篇教程探讨了大数据技术之一次KAFKA消费者异常引起的思考,希望阅读本篇文章以后大家有所收获,帮助大家对相关内容的理解更加深入. 问题描述: 线上出现一台服务器特别慢,于是关闭了服务器上的kafka ...

  3. python消费kafka逻辑处理导致cpu升高_Kafka 消费迟滞监控工具 Burrow

    Kafka 官方对于自身的 LAG 监控并没有太好的方法,虽然Kafka broker 自带有 kafka-topic.sh, kafka-consumer-groups.sh, kafka-cons ...

  4. python 死循环程序能占满cpu吗_运行tensorflow python程序,限制对GPU和CPU的占用操作...

    一般情况下,运行tensorflow时,默认会占用可以看见的所有GPU,那么就会导致其它用户或程序无GPU可用,那么就需要限制程序对GPU的占用.并且,一般我们的程序也用不了所有的GPU资源,只是强行 ...

  5. python整体向右缩进两个级别_关于python:IndentationError:unindent与任何外部缩进级别都不匹配...

    当我编译下面的python代码时,我得到 IndentationError: unindent does not match any outer indentation level import sy ...

  6. python与其他的数据分析有什么区别_学好python和数据分析有什么关系?

    1. 应用数学.统计学.金融学等相关专业,硕士及以上学历. 2. 有良好的产品Sense和商业敏感度,有2年以上电商.物流.零售等数据分析经验. 3. 精通SQL,有一定的Python或者R编程能力, ...

  7. python转exe怎么不会被杀毒软件_使用Python Shells绕过杀毒软件

    一.绕过杀毒软件 Why? 1.使用绕过反病毒软件的方式要比禁用杀毒软件更加安全; 2.展示客户端的反病毒软件是多么脆弱的非常有趣. How? 如果你使用二进制,而这个二进制文件被You can by ...

  8. python 某个数是不是在某个范围内_这个Python入门教程,国内12岁小孩都能做,是小白的入门不二之选...

    简介:你曾经想知道计算机是如何工作的吗?尽管我们不能在一篇文章里面教会你所有的东西,但是可以通过学习如何写出你自己的程序来获得一个良好的开端.在这篇Python教程中,你将会学到计算机编程的基础知识, ...

  9. python对电脑配置的要求高吗_学python最电脑配置有要求么

    python对于电脑硬件基本没什么要求,下载python安装程序的时候,注意看下自己电脑属性是64位系统还是32位系统,再下载对应的python安装程序. 单纯学Python的话普通电脑就ok了,机器 ...

最新文章

  1. 老手讲解在JSP开发中与Web的中文问题解决方法
  2. 对偶问题复习要点整理
  3. boost::hana::tuple_t用法的测试程序
  4. nbiot开发需要掌握什么_学习软件开发需要准备什么?
  5. php mysql bool_关于mysql api中my_bool的取值范围的问题
  6. linux 触摸屏在dev的那个目录下,各硬件设备在Linux中的文件名
  7. java分割两个时间段不在同月份
  8. Git学习笔记:常用命令总结
  9. 【NOIP2010】【Luogu1190】接水问题(给定顺序的模拟)
  10. spring security实战 3-使用授权码模式( Authorization Code grant)保护资源
  11. 本来都对象棋失去兴趣了, 是特殊的原因让我又开始从侧面搞象棋方面的擦边的游戏...
  12. Opencv官方样例图片下载
  13. excel VBA自动设置表格格式
  14. 通过网站端口攻击服务器,服务器被攻击怎么解决?从端口策略入手
  15. html alert属性可以自定义,Html自定义alert,confirm弹窗
  16. 小蓝本 第一本《因式分解技巧》第三章 分组分解 笔记(第三天)
  17. 用Excel进行个人敏捷项目看板管理
  18. 应运而生的环保APP
  19. JavaSE Lambda 表达式
  20. Excel数值、文本相互转换

热门文章

  1. java实现123n_用Java编程 :输入一个正整数n,输出n!的值。 其中n!=1*2*3*…*n。 求高手指点...
  2. 某计算机型号,某计算机的型号为486/33,其中33的含义是?
  3. SQL语言之DDL语言学习-----数据定义语言学习
  4. python 反转列表的3种方式
  5. 掌握Python字典的12个例子
  6. python logging模块之handlers的使用教程
  7. typedef enum的用法(枚举)
  8. python PyQt5 QLabel()(可以用来显示文字、图片或作为放置一些控件提示信息的容器)
  9. python pkl是什么类型的文件?怎么来打开它?(使用numpy和pickle都能打开)
  10. 字典、列表、元祖、字符串的综合(1)