介绍 Kafka Streams 的原理架构，常见配置以及在监控场景的应用。作者：来自 vivo 互联网服务器团队- Pang Haiyun

消息队列是重要的分布式系统组件，在高性能、高可用、低耦合等系统架构中扮演着重要作用。可用于异步通信、削峰填谷、解耦系统、数据缓存等多种业务场景。本文是关于消息队列（MQ）选型和常见问题的精心整理。在这篇文章中，我们将详细介绍消息队列的概念、作用以及如何选择适合自己需求的消息队列系统。

下面是Flink读取Kafka数据的代码，其中就有五种读取offset的方式，并配置相应的介绍。

对于大数据集群来说，监控功能是非常必要的，通过日志判断故障低效，我们需要完整的指标来帮我们管理Kafka集群。本文讨论Kafka的监控以及一些常用的第三方监控工具。

Flink SQL Connector生成工具支持根据不同数据源和连接方式可视化生成Flink SQL，目前支持的数据源类型有：Doris、MySQL、Kafka，支持的连接方式有JDBC、CDC。

在处理大量空间数据时，如何高效地判断一个点是否在一个地理围栏内是一个常见的需求。传统的方法是使用点和多边形之间的关系算法，但是当数据量大时，这种方法的性能会变得很低。为了解决这个问题，可以使用 R 树索引来加速判断。

今天，跟大家分享一下kafka 的存储机制及如何根据 offset 查找消息的。

图文手册，教你如何一步步连接共享集群中的Kafka组件。

Flink消费Kafka写Doris

Kafka Explorer连接SASL_PLAINTEXT PLAINT认证Kafka