Kafka宕机引发的高可用问题 问题要从一次Kafka的宕机开始说起。 笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部使用的Kafk ...
分类：
其他好文 时间：
2021-06-02 14:22:26
阅读次数：
0
I am in a bit of a bind (pun intended). I have a ubuntu server running kafka & zookeeper. This server has both ipv4 and ipv6 protocols installed. In t ...
分类：
其他好文 时间：
2021-06-02 12:29:05
阅读次数：
0
Kafka Exactly Once语义 精准一次: 将服务器的ACK级别设置为-1,可以保证Producer到Server之间不会丢失数据，即At Least Once语义。相对的，将服务器ACK级别设置为0，可以保证生产者每条消息只会被发送一次，即At Most Once语义。 At Least ...
分类：
其他好文 时间：
2021-06-02 12:21:04
阅读次数：
0
面试题: 1）Kafka中的ISR(InSyncRepli)、OSR(OutSyncRepli)、AR(AllRepli)代表什么？ 2）Kafka中的HW、LEO等分别代表什么？ 3）Kafka中是怎么体现消息顺序性的？ 4）Kafka中的分区器、序列化器、拦截器是否了解？它们之间的处理顺序是什么 ...
分类：
其他好文 时间：
2021-06-02 12:19:54
阅读次数：
0
Kafka概述 Kafka是一个基于发布、订阅的分布式消息队列,用于大数据实时处理。 为什么要用kafka? 注册信息的过程,先在网站上填写注册信息,后台会调用其他服务的接口,反馈给网页注册成功信息,最后再显示给用户,并且将短信发送给用户,该过程为同步通信过程,需要同步等待，由于同步通信的过程比较慢 ...
分类：
其他好文 时间：
2021-06-02 12:12:15
阅读次数：
0
#模式匹配 TODO - 模式匹配 - 匹配规则 1.类似于java中switch 2.当数据满足某一个分支时，执行完毕后，就直接跳出 3.case _ 分支类似于default语言， 分支匹配其实就是顺序匹配 4.如果数据没有匹配任何规则，会发生错误 模式匹配语法中，采用match关键字声明，每个 ...
分类：
其他好文 时间：
2021-06-02 10:38:15
阅读次数：
0
map源码 //第一个参数传入一个函数,第二个参数为隐式参数，返回值和集合的类型一致都是B def map[B, That](f: A => B)(implicit bf: CanBuildFrom[Repr, B, That]): That = { //方法内部定义builder方法 def bu ...
分类：
其他好文 时间：
2021-06-02 10:36:00
阅读次数：
0
python 实现 kakfa 的 生产消费模式 和 发布订阅模式（已安装好 kafka 的情况下） 生产者 producer_demo.py from kafka import KafkaProducer, KafkaConsumer from kafka.errors import kafka_ ...
分类：
编程语言 时间：
2021-05-24 16:44:34
阅读次数：
0
astclick：可以处理移动端click事件300毫秒延迟 1、兼容性 iOS 3及更高版本的移动Safari iOS 5及更高版本的Chrome Android上的Chrome（ICS） Opera Mobile 11.5及以上版本 Android 2以来的Android浏览器 PlayBook ...
分类：
移动开发 时间：
2021-05-24 15:19:24
阅读次数：
0
Scala语言类型（同java） 静态，强，类型推断, 弱类型：(javascripte) > "1"+2 '12' 强类型：(java,scala,python) >>> "1"+2 TypeError: cannot concatenate 'str' and 'int' objects 动态类 ...
分类：
其他好文 时间：
2021-05-24 14:04:24
阅读次数：
0
