队列（Queue）：与栈相对的一种数据结构，集合（Collection）的一个子类。队列允许在一端进行插入操作，而在另一端进行删除操作的线性表，栈的特点是后进先出，而队列的特点是先进先出。队列的用处很大，比如实现消息队列。Queue类关系图，如下图所示：注：为了让读者更直观地理解，上图为精简版的Queue类关系图。本文如无特殊说明，内容都是基于Java1.8版本。队列（Queue）1）Queue分
分类：
其他好文 时间：
2020-08-02 10:18:18
阅读次数：
73
0、题记实际业务场景中，会遇到基础数据存在Mysql中，实时写入数据量比较大的情景。迁移至kafka是一种比较好的业务选型方案。而mysql写入kafka的选型方案有：方案一：logstash_output_kafka插件。方案二：kafka_connector。方案三：debezium插件。方案四：flume。方案五：其他类似方案。其中：debezium和flume是基于mysqlbinlog实
分类：
数据库 时间：
2020-08-01 12:38:39
阅读次数：
93
查看消费组详情: ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group 查看topic详情： ./bin/kafka-topics.sh --to ...
分类：
其他好文 时间：
2020-07-31 18:03:33
阅读次数：
83
需求：将/dev/vdb扩展至150G环境：内核为：2.6.32-220.23.2.al.ali1.2.alios6.x86_64ECS主机步骤0、扩容是高风险操作，创建磁盘快照1、通过控制台对云盘进行扩展；2、云盘在线扩展后fdisk-l查询磁盘并未扩展；通过文档内核3.0以上才可以在线扩展磁盘，3.0以下必须要重启，磁盘resan的方式也没有扫出来3、重启后，fdisk-l可查询到已经扩展4、
分类：
其他好文 时间：
2020-07-31 12:36:57
阅读次数：
82
一次机房停电引发的思考今天早上到公司的时候，接到开发反馈DEV环境所有接口都卡，耗时都在一分钟以上，严重影响开发正常工作，然后通过网关的日志定位到原因是因为kafka集群不可用（总共3个broker，前一天晚上机房停电导致leader节点挂了），导致网关的反爬过滤器里面发送kafka消息的代码kafkaTemplat.send阻塞了60s，当时在想这个send方法不是异步的吗，为什么会阻塞60s？
分类：
其他好文 时间：
2020-07-31 01:13:59
阅读次数：
93
一、安装JDK 略过 二、安装Zookeeper 由于Kafka的运行依赖于Zookeeper，所以在运行Kafka之前需要安装并运行Zookeeper 1.Zookeeper下载路径 http://zookeeper.apache.org/releases.html#download 2.解压到文 ...
分类：
其他好文 时间：
2020-07-30 22:13:36
阅读次数：
66
[AHOI2014]支线剧情(有上下界的网络流) 题面 JYY现在所玩的RPG游戏中，一共有N个剧情点，由1到N编号，第i个剧情点可以根据JYY的不同的选择，而经过不同的支线剧情，前往Ki种不同的新的剧情点。当然如果为0，则说明i号剧情点是游戏的一个结局了。 JYY观看一个支线剧情需要一定的时间。J ...
分类：
其他好文 时间：
2020-07-30 16:54:49
阅读次数：
76
