kafka kafka-stream机制stream
RabbitMQ、RocketMQ、Kafka延迟队列实现
延迟队列在实际项目中有非常多的应用场景，最常见的比如订单未支付，超时取消订单，在创建订单的时候发送一条延迟消息，达到延迟时间之后消费者收到消息，如果订单没有支付的话，那么就取消订单。 那么，今天我们需要来谈的问题就是RabbitMQ、RocketMQ、Kafka中分别是怎么实现延时队列的，以及他们对 ......
解决RockyLinux和Centos Stream 9中firefox无法播放HTML视频问题
如题在测试两种centos后续系统时，发现firefox无法播放HTML视频问题。经过一番折腾找到了解决的办法，具体解决如下： 首先下载VLC $sudo yum install vlc 而后重启浏览器就可以使用firefox播放HTML视频了。 在下载vlc时会因为仓库问题出错， 对于Rocky， ......
轻量级的架构决策记录机制
作者：倪新明 ADR是一种性价比非常高的架构决策文档化实践，团队引入和实践成本很低，却能为团队带来极大收益！ 1 团队研发面临的问题 不论是在传统的IT行业，还是互联网行业，研发团队在架构决策层面或多或少的都会面临以下问题或挑战： •新成员加入团队，对系统现有的架构决策可能会盲目遵守，只知其然，不知 ......
JS执行机制及ES6
一、JS执行机制 JS语言有个特点是单线程，即同一时间只能做一件事。单线程就意味着，所有的任务需要排队，前一个任务结束，才会执行后一个任务，可能造成页面渲染不连贯。 为了解决这个问题，利用多核CPU的计算能力，允许JS脚本创建多个线程，即同步和异步。 同步任务： 同步任务都在主线程上执行，形成一个执 ......
【机器学习】李宏毅——自注意力机制(Self-attention)
前面我们所讲的模型，输入都是一个向量，但有没有可能在某些场景中输入是多个向量，即一个向量集合，并且这些向量的数目并不是固定的呢？ 这一类的场景包括文字识别、语音识别、图网络等等。 那么先来考虑输出的类型，如果对于输入是多个数目不定的向量，可以有以下这几种输出方式： 每个向量对应一个输出：输出的数目与 ......
Kafka事务「原理剖析」
一、事务概览 提起事务，我们第一印象可能就是ACID，需要满足原子性、一致性、事务隔离级别等概念，那kafka的事务能做到什么程度呢？我们首先看一下如何使用事务 Producer端代码如下 KafkaProducer<String, String> producer = new KafkaProdu ......
Mybatis缓存机制
什么是缓存？ 为什么使用缓存？ 什么场景下使用缓存？ 缓存（Cache）就是数据交换的缓冲区，一个临时存储数据的地方，当我们读取数据时会首先从缓存中查找需要的数据，如果找到了则直接执行，找不到的话再从内存中找。 在实际开发中，我们会经常对数据库进行数据查询，而从数据库读取数据的效率是非常低下的，并且 ......
这么简单，还不会使用java8 stream流的map()方法吗？
一、前言 在日常的开发工作中经常碰到要处理list中数据的问题，比如从数据库中查出了很多学生，由于一些原因需要在内存中找出这些学生中的所有姓名，或者把名为“王五”的语文成绩暂时修改为“100”，这些问题怎么处理呐，之前我们想到的是遍历每个元素，然后取出来放到另外一个集合中，在java8中对集合可以进 ......
总算给女盆友讲明白了，如何使用stream流的filter()操作
一、引言 在上一篇文章中《这么简单，还不会使用java8 stream流的map()方法吗？》分享了使用stream的map()方法，不知道小伙伴还有印象吗，先来回顾下要点，map()方法是把一个流中的元素T转换为另外一个新流中的元素R，转换完成后两个流的元素个数不发生改变，具体怎么使用，请小伙伴移 ......
重新认识下JVM级别的本地缓存框架Guava Cache(3)——探寻实现细节与核心机制
本篇文章我们将进一步探讨下Guava Cache 实现层面的一些逻辑与设计策略，让我们可以对Guava Cache整体有个更加明朗的认识，促进实际使用中对其的理解。 ......
go操作Kafka
1. Kafka介绍 1.1.1. Kafka是什么 kafka使用scala开发，支持多语言客户端（c++、java、python、go等） Kafka最先由LinkedIn公司开发，之后成为Apache的顶级项目。 Kafka是一个分布式的、分区化、可复制提交的日志服务 LinkedIn使用Ka ......
python进阶（28）import导入机制原理
前言 在Python中，一个.py文件代表一个Module。在Module中可以是任何的符合Python文件格式的Python脚本。了解Module导入机制大有用处。 1. Module组成 一个.py文件就是一个module。Module中包括attribute, function等。 这里说的a ......
Flink SQL管理平台flink-streaming-platform-web安装搭建
文章都在个人博客网站：https://www.ikeguang.com/ 同步，欢迎访问。 最近看到有人在用flink sql的页面管理平台，大致看了下，尝试安装使用，比原生的flink sql界面确实好用多了，我们看下原生的，通过bin/sql-client.sh命令进入那个黑框，一只松鼠，对，就 ......
Flink同步Kafka数据到ClickHouse分布式表
公众号文章都在个人博客网站：https://www.ikeguang.com/ 同步，欢迎访问。 业务需要一种OLAP引擎，可以做到实时写入存储和查询计算功能，提供高效、稳健的实时数据服务，最终决定ClickHouse。 什么是ClickHouse？ ClickHouse是一个用于联机分析(OLAP ......
基于LSM树的存储机制简述
下午听了关于MyRocks-PASV的研究讲座，很有意思所以学习了一下LSM树的一些简单的底层原理。现在整理一下 我们都知道目前Key:Value型的数据库普遍较之关系型数据库有着更好的表现，为什么会有这样的一个差异呢？关键就在于存储形式和读写机制的不同。 Key:Value型数据库可以通过LSM ......
痞子衡嵌入式：MCUXpresso IDE下高度灵活的FreeMarker链接文件模板机制
大家好，我是痞子衡，是正经搞技术的痞子。今天痞子衡给大家分享的是MCUXpresso IDE下高度灵活的FreeMarker链接文件模板机制。 痞子衡之前写过一篇文章 《MCUXpresso IDE下工程链接文件配置管理与自动生成机制》，这篇文章介绍了 MCUXpresso IDE 在链接文件管理设 ......