# 云消息队列 Kafka 版 #
0
关注
10043内容
Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL
《Flink SQL 1.9.0 技术内幕和最佳实践》，许多小伙伴对演示环节的 Demo 代码非常感兴趣，迫不及待地想尝试下，所以写了这篇文章分享下这份代码。
|
ActiveMQ系列：一个MQ产品的基础知识
AMQP，即Advanced Message Queuing Protocol，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品、不同开发语言等条件的限制。
如何为Kafka加上账号密码（二）
本小节我们就为Kafka添加最简单的认证方式，也就是SASL_PLAINTEXT（即SASL/PLAIN+ 非加密通道）。
|
Flume【基础知识 01】简介 + 基本架构及核心概念 + 架构模式 + Agent内部原理 + 配置格式（一篇即可入门Flume）
【2月更文挑战第18天】Flume【基础知识 01】简介 + 基本架构及核心概念 + 架构模式 + Agent内部原理 + 配置格式（一篇即可入门Flume）
微服务架构设计与实践：用Spring Cloud实现抖音的推荐系统
本文基于Spring Cloud实现了一个简化的抖音推荐系统，涵盖用户行为管理、视频资源管理、个性化推荐和实时数据处理四大核心功能。通过Eureka进行服务注册与发现，使用Feign实现服务间调用，并借助Redis缓存用户画像，Kafka传递用户行为数据。文章详细介绍了项目搭建、服务创建及配置过程，包括用户服务、视频服务、推荐服务和数据处理服务的开发步骤。最后，通过业务测试验证了系统的功能，并引入Resilience4j实现服务降级，确保系统在部分服务故障时仍能正常运行。此示例旨在帮助读者理解微服务架构的设计思路与实践方法。
Flink CDC 2.0 正式发布，详解核心改进
Flink CDC 2.0.0 版本于 8 月 10 日正式发布，点击了解详情～
别再乱排查了！Kafka 消息积压、重复、丢失，根源基本都是 Rebalance！
大家好，我是小富～分享一次Kafka消息积压排查经历：消费者组因Rebalance导致消费能力骤降。本文详解Rebalance触发场景（消费者变更、分区扩容、订阅变化、超时等），剖析其引发的消息积压、重复消费、丢失等问题根源，并提供优化方案：调优超时参数、手动提交offset、启用粘性分配策略、保障消费幂等性。掌握这些，轻松应对Kafka常见故障！
免费试用