0、题记实际业务场景中，会遇到基础数据存在Mysql中，实时写入数据量比较大的情景。迁移至kafka是一种比较好的业务选型方案。而mysql写入kafka的选型方案有：方案一：logstash_output_kafka插件。方案二：kafka_connector。方案三：debezium插件。方案四：flume。方案五：其他类似方案。其中：debezium和flume是基于mysqlbinlog实
分类：
数据库 时间：
2020-12-15 12:34:47
阅读次数：
9
一、容器刷新前源码分析 做过 SSM 框架整合的都会知道,如果我们需要启动项目,需要在 web.xml 中进行如下配置 <!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http:// ...
分类：
编程语言 时间：
2020-12-14 13:47:27
阅读次数：
6
从端口读数据读取到本地文件 #1.给三个组件命名 a3.sources = r1 a3.channels = c1 a3.sinks = k1 #2.给source组件属性赋值 a3.sources.r1.type = avro a3.sources.r1.bind = hadoop102 a3.s ...
分类：
Web程序 时间：
2020-12-14 12:51:33
阅读次数：
7
本文主要分享Netty中PoolChunk如何管理内存。 源码分析基于Netty 4.1.52 内存管理算法 首先说明PoolChunk内存组织方式。 PoolChunk的内存大小默认是16M，Netty将它划分为2048个page，每个page为8K。 PoolChunk上可以分配Normal内存 ...
分类：
Web程序 时间：
2020-12-10 11:25:28
阅读次数：
10
一、前言 由上篇文章我们得知，SpringBoot启动时，就是有很简单的一行代码。那我们可以很清楚的看到这行代码的主角便是SpringApplication了，本文我们就来聊一聊这货，来探寻SpringBoot的一站式启动流程。 其实SpringApplication是将一个典型的Spring应用的启动流程”模板化”了，在没有特殊定制需求的情况下，默认的模板化后的执行流程就能满足我们的需求了。
分类：
编程语言 时间：
2020-12-10 11:07:48
阅读次数：
4
参考： https://blog.csdn.net/u014730165/article/details/84065996 https://www.jianshu.com/p/69a6ae850736 Java多线程之Future实现原理和源码分析 1、概述 从上面章节的学习，我们了解到，每个执行的 ...
分类：
其他好文 时间：
2020-12-10 10:44:02
阅读次数：
1
微信公众号：[中间件兴趣圈]作者简介：《RocketMQ技术内幕》作者本文将重点分析一下dubbo限流的另外一个方式，tps过滤器。@Activate(group=Constants.PROVIDER,value=Constants.TPS_LIMIT_RATE_KEY)过滤器作用服务调用tps过滤器使用场景对Dubbo服务提供者实现限流(tps)。阻断条件当服务调用者超过其TPS时，直接返回rp
分类：
其他好文 时间：
2020-12-08 12:47:05
阅读次数：
4
温馨提示：本文基于Kafka2.2.1版本。如果觉得源码阅读比较枯燥，本文的中间有Sender线程的工作流程图。上文《源码分析Kafka消息发送流程》已经详细介绍了KafkaProducersend方法的流程，该方法只是将消息追加到KafKaProducer的缓存中，并未真正的向broker发送消息，本文将来探讨Kafka的Sender线程。在KafkaProducer中会启动一个单独的线程，其名
分类：
编程语言 时间：
2020-12-08 12:00:53
阅读次数：
6
温馨提示：本文基于Kafka2.2.1版本。本文主要是以源码的手段一步一步探究消息发送流程，如果对源码不感兴趣，可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构图。从上文初识KafkaProducer生产者，可以通过KafkaProducer的send方法发送消息，send方法的声明如下：Future<RecordMetadata>send(ProducerRecord&l
分类：
其他好文 时间：
2020-12-08 11:59:45
阅读次数：
3
温馨提示：由于微信单篇文章的字数限制，RocketMQDLedger日志复制分为两篇文章介绍。本篇紧接着上文源码分析RocketMQDLedger(多副本)之日志复制-上篇。3、EntryHandler详解EntryHandler同样是一个线程，当节点状态为从节点时激活。3.1核心类图其核心属性如下：longlastCheckFastForwardTimeMs上一次检查主服务器是否有push消息的
分类：
其他好文 时间：
2020-12-07 12:47:18
阅读次数：
11
