K8S的Kafka监控(Prometheus+Grafana)
欢迎访问我的GitHubhttps://github.com/zq2599/blog\_demos(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fgithub.com%2Fzq2599%2Fblog_demos)内容：所有原创文章分类汇总及配套源码，涉及Java、Doc
Kafka高可用，高吞吐量低延迟的高并发的特性背后实现机制
1概述Kafka是最初由Linkedin公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式消息系统，Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。2消息系统介绍一个消息系统负责将数据从一个应用传递到另外一个应用，应用只需关注于数据，无需关注数据在两个或
Kafka、RabbitMQ、RocketMQ消息中间件的对比 —— 消息发送性能
引言分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品RocketMQ(MetaQ的内核)也顺利开源,得到大家的关注。那么,消息中间件性能究竟哪家强?带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了性
Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL
上周六在深圳分享了《FlinkSQL1.9.0技术内幕和最佳实践》，会后许多小伙伴对最后演示环节的Demo代码非常感兴趣，迫不及待地想尝试下，所以写了这篇文章分享下这份代码。希望对于FlinkSQL的初学者能有所帮助。完整分享可以观看Meetup视频回顾：https://developer.aliyun.com/live/1416(
Kafka 消息丢失与消费精确一次性
点击上方“技术最TOP”，星标公众号重磅干货，第一时间送达!(https://oscimg.oschina.net/oscnet/9b099440eb6f4b85ad2b3da01334abf3.png)技术最TOP扒最前沿科技动态，聊最TOP编程技术。关注(https://www.oschina.
Kafka、RabbitMQ、RocketMQ等消息中间件的对比
点击上方蓝色字体，选择“标星公众号”优质文章，第一时间送达76套java从入门到精通实战课程分享(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzg4ODA3NTk0Nw%3D%3D%26mid%3D2
SpringBoot2 整合Kafka组件，应用案例和流程详解
本文源码：GitHub·点这里(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fgithub.com%2Fcicadasmile%2Fmiddlewareparent)||GitEE·点这里(https://gitee.com/cicadasmile/middleware
MQ之对比
activeMQ：高效、可扩展、稳定安全企业级消息通信rabbitMQ：分布式系统可靠、可扩展、功能丰富，内存式堆积，某些条件下触发换页动作将内存中消息换页到磁盘；支持多租户 不支持重试队列，二次封装延迟队列实现呢 拉模式，不回溯，支持消息追踪 多租户kafka：高吞吐量分布式发布订阅消息系统，可水平扩展，磁盘式堆积，冗余功能
CDS是一个企业级的持续交付和DevOps自动化开源平台
CDS是一个企业级的持续交付和DevOps自动化开源平台弹性CDS资源/worker是按需启动的，以确保用户的等待时间较短，并且不会过度消耗空闲资源可扩展的在CDS中，任何类型的操作(Kubernetes和OpenStack部署、推送到Kafka、cve的测试……)都可以在高级插件中捕获，供用户作为构建块使用。这些插件易于编写和使
Kafka 发送消息过程中拦截器的用途？
消息在通过send()方法发往broker的过程中，有可能需要经过拦截、序列化器(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzU3OTc1MDM1Mg%3D%3D%26mid%3D2247497846%26i