1，Context:不需要在任何组件间添加props方法，可以任意之间的组件树进行 const Context = React.createContext(); const Provider = Context.Provider; //提供者 const Consumer = Context.Con ...
分类：
其他好文 时间：
2020-01-11 20:22:28
阅读次数：
88
Apache Kafka是一个开放源代码流处理软件平台，用于处理实时数据存储。Apache Kafka在两方（即发送方和接收方）之间充当经纪人。它一天可以处理大约数万亿个数据事件。Apache Kafka是一个基于分布式流式处理过程的软件平台。Apache Kafka是一个发布-订阅消息传递系统，它... ...
分类：
Web程序 时间：
2020-01-11 15:20:11
阅读次数：
112
原文链接:https://cloud.tencent.com/developer/article/1462432 一、概述 在新消费者客户端中，消费位移是存储在Kafka内部的主题 __consumer_offsets 中。把消费位移存储起来（持久化）的动作称为 “提交” ，消费者在消费完消息之后需 ...
分类：
其他好文 时间：
2020-01-10 22:36:40
阅读次数：
150
1.变量定义： num = 2+2 num = "2"+2 num = "2"+"2" str = "string"..'string' str = [[ string ]] 2.定义表格： tab = {k="kk",v="vv"} tab = {k="kk","vv"} tab = {"kk". ...
分类：
编程语言 时间：
2020-01-10 15:26:47
阅读次数：
79
测试环境、预发布环境经过QA多番测试没有遇到问题，但在一次上线过程中，在线上环境出现20秒的响应超时，这个毫无疑问，环境问题。 尽管线上数据量大，可Mysql以不至于慢到20秒，而且发现每次技术都是20.01~20.04秒之间，相差不到一秒钟，mysql也不至于这么均匀，在好奇心下，运维大神配合查了 ...
分类：
Web程序 时间：
2020-01-09 22:42:11
阅读次数：
132
Kafka作为时下最流行的开源消息系统，被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统，Kafka在保障了大部分功能特性的同时，还提供了超一流的读写性能。 针对Kafka性能方面进行简单分析，相关数据请参考：https://segmentfau ...
分类：
其他好文 时间：
2020-01-09 20:48:30
阅读次数：
79
今天是继续对之前 kafka 集群遗留问题的查漏补缺。 扩容后对副本进行再平衡： 今天检查 kafka manager 发现了一个 __consumer_offsets 主题（消费者分区位移保存主题）的 leader 副本只被部署在了已有三节点中的两个节点上。并没有将三个 broker 上都平均分布 ...
分类：
其他好文 时间：
2020-01-09 18:39:38
阅读次数：
83
//暂停kafka的消费 暂停分区的分配consumer.unsubscribe();//此处不取消订阅暂停太久会出现订阅超时的错误consumer.pause(consumer.assignment());//重新消费分区,此处不重新分配会出错 this.open(null,null,null); ...
分类：
其他好文 时间：
2020-01-09 18:39:24
阅读次数：
1033
我在要完成这个需求的时候大概有两个思路。 第一种方法： 我们直接使用 Kafka 提供的 bin 工具，去把我们关心的 lag 值 show 出来然后通过代码处理一下报出来。例如： 我们可以起个远程的 cmd 脚本，定期去执行 kafka-consumer-groups.sh 工具然后通过 awk ...
分类：
编程语言 时间：
2020-01-08 19:08:27
阅读次数：
102
Linux网络统计工具/命令 https://linux.cn/article-5578-1.html 作者： nixCraft 译者： LCTT ??? | 2015-06-08 09:15 收藏: 6 我在Linux(基于CentOS 或者 Debian 的发行版)中该如何查看当前网络端口吞吐量 ...
分类：
系统相关 时间：
2020-01-04 18:17:06
阅读次数：
122
