kafka
-
Ubuntu安装RabbitMQ集群
❝ 一般来说,如果只是为了学习 RabbitMQ 或者验证业务工程的正确性那么在本地环境或者测试环境上使用其单实例部署就可以了,但是出于 MQ 中间件本身的可靠性、并发性、吞吐量和…
-
项目里没用过设计模式？看看 Nest.js 怎么用的
设计模式是前人总结的代码架构方式，主要是针对面向对象的代码。 JS 代码在 es6 中加入了 class 的支持，TS 又实现了 interface 和 abstract clas…
-
让消费数据处理更快版本2(有并发控制)-一次性并发获取或者初始化任务最快有效方式
让消费数据处理更快版本2 一次性获取或者初始化所有数据并发模式 上个版本Go让消费速度更快我们重点有个LOOP，那就表明它是在后台一直运行的，那如果我们想一次性执行并发获取任务或者…
-
Kafka中ACKS LSO LEO LW HW AR ISR OSR解析
前言 Kafka中ACKS三种策略，LSO、LEO、LW、HW、AR、ISR、OSR解析。 名称解释 ACKS（Acknowledgments）确认、回执 LW（Low water…
-
Kafka消息与索引详解
前言 以kafka_2.13-2.8.0为例，分析Kafka消息在磁盘上的存储结构、配置以及如何通过索引找到具体的消息数据。 分区目录 一个分区（Partition）有1到多个副本…
-
在Linux搭建Kafka集群
前言 以kafka_2.13-2.8.0版本做示例，安装架构图如下所示，4台服务器，4个节点的Zookeeper集群（1主2从1观察）以及3个Kafka服务。 image-2021…
-
DataHub：现代数据堆栈的元数据平台
《开源精选》是我们分享 Github、Gitee 等开源社区中优质项目的栏目，包括技术、学习、实用与各种有趣的内容。本期推荐的是 DataHub 一个现代数据堆栈的开源元数据平台。…
-
浅谈Flink(四)之Table API和SQL
大家好我是栗子鑫，今天主要想给大家介绍一下FlinkAPI的一种Table API和SQL，希望对大家有所帮助，正文如下： 上一篇公众号介绍了三种API的DataStream，今天…
-
面试必备：kafka夺命连环11问
大家好，我是田螺。 年后应该很多小伙伴找工作，所以给大家来个kafka的11连问，加油~ 说说你对kafka的理解 kafka是一个流式数据处理平台，他具有消息系统的能力，也有实时…
-
【Go实现】实践GoF的23种设计模式：观察者模式
上一篇：【Go实现】实践GoF的23种设计模式：装饰者模式 简单的分布式应用系统（示例代码工程）：https://github.com/ruanrunxue/Practice-De…
-
架构设计 8-高可用架构设计之故障处理
导读：《架构设计》系列为极客时间李运华老师《从0开始学架构》课程笔记。本文为第八部分，主要介绍故障处理，包口典型表现、原因、常见情况、解决思想以及解决方法。如果异地多活看作事前处理…
