kafka外网访问疑云
前言
最近在搭建数据实时捕获和传输管道(CDC)时用到了kafka,首先在阿里云ECS上搭建了一个最简单的kafka实例,因为是阿里云内网ECS,经测试无误后通过公网映射出来到公司网络环境提供服务,主要后面需要将DTS中的数据塞到kafka提供到本地调试。
SpringBoot学习历程
经过同事介绍,听说了SpringBoot框架,并且亲身感受过这个框架的优势,经过一段时间的学习和使用,故此写博客记录自己学习SpringBoot的全部历程。
ActiveMQ session.close与session.commit的区别
如果session是以非事务的方式创建必须session.close()就可以将消息提交到服务器队列
session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); // 创建Session
session.close();
如果session是以开启事务的方式创建必须session.commit()
如何构建批流一体数据融合平台的一致性语义保证?
本文根据陈肃老师在 Apache Kafka x Flink Meetup 深圳站的分享整理而成,文章首先将从数据融合角度,谈一下 DataPipeline 对批流一体架构的看法,以及如何设计和使用一个基础框架。其次,数据的一致性是进行数据融合时最基础的问题。
阿里、百度、美团都在用的‘高并发系统设计’;秒杀、抢红包、12306抢票等高并发场景难点
"秒杀活动"、"抢红包"、"微博热搜"、"12306抢票"、"共享单车拉新"等都是高并发的典型业务场景,那么如何解决这些业务场景背后的难点问题呢?
秒杀系统中,QPS达到10万/s时,如何定位并解决业务瓶颈?
明星婚恋话题不断弓|爆微博热搜,如何确保系统不宕机?
共享单车充值活动,如何保证不超卖?
......
同一时间、海量用户的高频访问对任何平台都是难题,但可喜的是,虽然业务场景不同,设计和优化的思想却是万变不离宗。
今日头条在消息服务平台和容灾体系建设方面的实践与思考
本篇文章整理自今日头条的沈辉在 RocketMQ 开发者沙龙中的演讲,主要和大家分享一下,RocketMQ 在微服务架构下的实践和容灾体系建设。沈辉是今日头条的架构师,主要负责 RocketMQ 在头条的落地以及架构设计,参与消息系统的时间大概一年左右。