#
项目需求：将kafka解析来的日志获取到数据库的变更记录，按照订单的级别和订单明细级别写入数据库，一条订单的所有信息包括各种维度信息均保存在一条json中，写入mysql5.7中。 配置信息： [
前提 假设你了解过 SpringBoot 和 Kafka。 1、SpringBoot 如果对 SpringBoot 不了解的话，建议去看看 DD 大佬 和 纯洁的微笑 的系列博客。 2、Kafka K
最近在学习Kafka，准备测试集群状态的时候感觉无论是开三台虚拟机或者在一台虚拟机开辟三个不同的端口号都太麻烦了（嗯。。主要是懒）。 环境准备 一台可以上网且有CentOS7虚拟机的电脑 为什么使用虚
Background In flink 1.5 above, it provides a new kafka producer implementation: FlinkKafkaProducer01
一、环境准备1、软件zookeeper3.4.11 https://www.apache.org/dyn/closer.cgi/zookeeper/kafka1.0.0 htt
我们知道kafka是基于TCP连接的。其并没有像很多中间件使用netty作为TCP服务器。而是自己基于Java NIO写了一套。几个重要类先看下Kafka Client的网络层架构。本文主要分析的是N
在一个月黑风高的夜晚，突然收到现网生产环境 Kafka 消息积压的告警，梦中惊醒啊，马上起来排查日志。 问题现象：消费请求卡死在查找 Coordinator
Goldengate到kafka配置详解 环境介绍： 源端数据库版本 源端OGG版本
收到业务部门需求，要求将Oracle数据库某表同步至Mysql数据库中，异构环境我们用kafka来实现，下面是具体的一些配置； 由于业务需要，现申请使用架构组数据同步服务同步以下数据到管家MySQL数
在设计大型系统的架构时，常常要考虑高并发/组件解耦/流量削峰等问题。此时，就必须要用到消息组件。消息队列常见的使用场景有 3 个：解耦、异步(高并发)、削峰。 常见的消息组件有：Kafka、Activ
