1.Kafka 中的 ISR(InSyncRepli)、OSR(OutSyncRepli)、AR(AllRepli)代表什么? 1、AR = ISR+OSR ISR: kafka 使用多副本来保证消息不丢失，多副本就涉及到kafka的复制机制，在一个超大规模的集群中，时不时地这个点磁盘坏了，那个点c ...
分类：
其他好文 时间：
2020-08-09 14:23:57
阅读次数：
86
A real case which is related to Automatic Delta Handling I use a ticket which I am struggling with recently to start this blog. It took me almost the ...
分类：
Web程序 时间：
2020-08-06 13:09:48
阅读次数：
101
最近看了@JavaGuide发布的一篇『面试官问我如何保证Kafka不丢失消息?我哭了！』，这篇文章承接这个主题，来聊聊如何保证RocketMQ不丢失消息。0x00.消息的发送流程一条消息从生产到被消费，将会经历三个阶段：生产阶段，Producer新建消息，然后通过网络将消息投递给MQBroker存储阶段，消息将会存储在Broker端磁盘中消息阶段，Consumer将会从Broker拉取消息以上任
分类：
其他好文 时间：
2020-08-05 18:15:11
阅读次数：
81
Lambda表达式（也称为闭包），它允许我们将函数当成参数传递给某个方法，或者把代码本身当作数据处理。很多语言（Groovy、Scala等）从设计之初就支持Lambda表达式。但是java中使用的是匿名内部类代替。最后借助强大的社区力量，找了一个折中的Lambda实现方案，可以实现简洁而紧凑的语言结构。1、匿名内部类到Lambda的演化?匿名内部类，即一个没有名字的，存在于一个类或方法内部的类。当
分类：
编程语言 时间：
2020-08-02 10:02:48
阅读次数：
78
查看消费组详情: ./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
#1.1 kafka启动命令nohup bin/kafka-server-start.sh config/server.properties & #1.2 kafka停止命令bin/kafka-server-stop.sh #1.3. kafka重启systemctl restart kafka # ...
分类：
其他好文 时间：
2020-07-30 14:45:42
阅读次数：
79
Multiprocessing.Pool可以提供指定数量的进程供用户调用，当有新的请求提交到pool中时，如果池还没有满，那么就会创建一个新的进程用来执行该请求；但如果池中的进程数已经达到规定最大值，那么该请求就会等待，直到池中有进程结束，才会创建新的进程来执行它。Pool类用于需要执行的目标很多， ...
分类：
系统相关 时间：
2020-07-29 17:53:42
阅读次数：
93
https://zhuanlan.zhihu.com/p/159017211 看着这算法凌乱的很，太复杂了！说实话，确实挺复杂，蛮罗嗦的，但是代数法可以得到如下表格： 假设4个queueConsumer有2个可以整除Consumer有3个不可整除Consumer有5个无法都分配queue[0]Con ...
分类：
其他好文 时间：
2020-07-29 10:19:02
阅读次数：
69
面向对象 一、面向对象 类(Class): 具有相同的属性和方法的对象的集合。定义每个对象所共有的属性和方法。对象是类的实例。 实例化：创建一个类的实例，类的具体对象（实例化的时候先开辟空间，再调用init，调用init的时候，总是把新开的空间作为参数传递给self）。 对象：通过类定义的数据结构实 ...
分类：
其他好文 时间：
2020-07-27 13:44:59
阅读次数：
81
