搜索结果
查询Tags标签： topic，共有 206条记录-
技术高手锤炼记
在职场混迹多年，见过菜鸟，遇过大神，不同的段位，不同的格局。 每个小蓝孩都有想成为英雄的梦想，同理，每个技术小白都希望跃迁为技术大牛。但凡事不可一蹴而就，在这成长的过程中，需要努力、汗水、专注度。我也是众多小白之一，偶然间读到一篇文章，颇有感触，遂拿出…
2021/12/8 23:49:46 人评论 次浏览 -
技术高手锤炼记
在职场混迹多年，见过菜鸟，遇过大神，不同的段位，不同的格局。 每个小蓝孩都有想成为英雄的梦想，同理，每个技术小白都希望跃迁为技术大牛。但凡事不可一蹴而就，在这成长的过程中，需要努力、汗水、专注度。我也是众多小白之一，偶然间读到一篇文章，颇有感触，遂拿出…
2021/12/8 23:49:46 人评论 次浏览 -
kafka集群管理指南
本指南使用的工具为kafka/bin目录下相关脚本。 添加/删除topics 可以使用如下命令进行新增topics：> bin/kafka-topics.sh --bootstrap-server broker_host:port --create --topic my_topic_name \--partitions 20 --replication-factor 3 --config x=y其中，—topic表…
2021/12/8 6:16:56 人评论 次浏览 -
kafka集群管理指南
本指南使用的工具为kafka/bin目录下相关脚本。 添加/删除topics 可以使用如下命令进行新增topics：> bin/kafka-topics.sh --bootstrap-server broker_host:port --create --topic my_topic_name \--partitions 20 --replication-factor 3 --config x=y其中，—topic表…
2021/12/8 6:16:56 人评论 次浏览 -
kafka在python中的使用及结束kafka消费者
先说下问题： 正常使用kafka消费者，接收消息时，会出现消息循环无法结束问题，增加参数 consumer_timeout_ms:超时时间（毫秒），超过指定时间没有获取到消息关闭kafka。（例子如下） consumer.py文件： from kafka import KafkaProducer, KafkaConsumer import timeclas…
2021/12/6 17:17:14 人评论 次浏览 -
kafka在python中的使用及结束kafka消费者
先说下问题： 正常使用kafka消费者，接收消息时，会出现消息循环无法结束问题，增加参数 consumer_timeout_ms:超时时间（毫秒），超过指定时间没有获取到消息关闭kafka。（例子如下） consumer.py文件： from kafka import KafkaProducer, KafkaConsumer import timeclas…
2021/12/6 17:17:14 人评论 次浏览 -
kafka 学习笔记1
Event streaming is the digital equivalent of the human body’s central nervous system概述 分布式基于发布/订阅模式的消息队列，应用于大数据实时处理领域。 1 6 3005 应用 异步处理 两种模式 点对点 消费者主动拉取消息发布订阅 一对多 消费者消费数据后不会清除消…
2021/12/1 23:10:05 人评论 次浏览 -
kafka 学习笔记1
Event streaming is the digital equivalent of the human body’s central nervous system概述 分布式基于发布/订阅模式的消息队列，应用于大数据实时处理领域。 1 6 3005 应用 异步处理 两种模式 点对点 消费者主动拉取消息发布订阅 一对多 消费者消费数据后不会清除消…
2021/12/1 23:10:05 人评论 次浏览 -
14) 21.11.29 浅谈 Kafka了解
1.认识Kafka Kafka对消息保存时依据Topic进行归类，发送消息成为Producer，消息接受者成为Consumer,此外Kafka集群有多个Kafka实例组成，每个实例（server）称为broker. 低版本之前集群，con和pro都依赖zk保证系统可用性，为集群保存meta信息。 2.概念 1）.Kafka作为一个集…
2021/11/29 23:36:21 人评论 次浏览 -
14) 21.11.29 浅谈 Kafka了解
1.认识Kafka Kafka对消息保存时依据Topic进行归类，发送消息成为Producer，消息接受者成为Consumer,此外Kafka集群有多个Kafka实例组成，每个实例（server）称为broker. 低版本之前集群，con和pro都依赖zk保证系统可用性，为集群保存meta信息。 2.概念 1）.Kafka作为一个集…
2021/11/29 23:36:21 人评论 次浏览 -
高并发异步解耦利器：RocketMQ究竟强在哪里？
上篇文章消息队列那么多，为什么建议深入了解下RabbitMQ？我们讲到了消息队列的发展史：并且详细介绍了RabbitMQ，其功能也是挺强大的，那么，为啥又要搞一个RocketMQ出来呢？是重复造轮子吗？本文我们就带大家来详细探讨RocketMQ究竟好在哪里。 RocketMQ是一个分布式消息…
2021/11/22 23:11:05 人评论 次浏览 -
高并发异步解耦利器：RocketMQ究竟强在哪里？
上篇文章消息队列那么多，为什么建议深入了解下RabbitMQ？我们讲到了消息队列的发展史：并且详细介绍了RabbitMQ，其功能也是挺强大的，那么，为啥又要搞一个RocketMQ出来呢？是重复造轮子吗？本文我们就带大家来详细探讨RocketMQ究竟好在哪里。 RocketMQ是一个分布式消息…
2021/11/22 23:11:05 人评论 次浏览 -
python 将xmind用例转换为excel用例
# -*- coding: utf-8 -*-from xmindparser import xmind_to_dictimport xlwt# 记录列数，全局变量，还原方便columnIndex = 0# 记录行数rowIndex = 1# 每个完整用例子主题的个数caseCount = 0def get_xmind_zen_dict(ws, main_topic):"""ws：工作表main_to…
2021/11/8 22:13:15 人评论 次浏览 -
python 将xmind用例转换为excel用例
# -*- coding: utf-8 -*-from xmindparser import xmind_to_dictimport xlwt# 记录列数，全局变量，还原方便columnIndex = 0# 记录行数rowIndex = 1# 每个完整用例子主题的个数caseCount = 0def get_xmind_zen_dict(ws, main_topic):"""ws：工作表main_to…
2021/11/8 22:13:15 人评论 次浏览 -
?志收集介绍
⽇志收集 项⽬背景 每个业务系统都有⽇志，当系统出现问题时，需要通过⽇志信息定位和解决问题。 当系统机器⽐较少 时，登陆到服务器上查看即可满⾜ 当系统机器规模巨⼤，登陆到机器上查看⼏乎不现实（分布式的系 统，⼀个系统部署在⼗⼏台机器上） 解决⽅案 把机器上的⽇…
2021/11/7 23:11:56 人评论 次浏览
