分类：kafka - 技术文章—

LSM Tree（log-structured merge-tree）是一种文件组织结构的数据结构，目前在不少数据库中都有使用到，如SQLite、LevelDB、HBase在Mongodb中也有一个LSM引擎；在传统的关系型数据库中使用的是B-/B+ tree作为索引的数据结构，B tre

在使用Java编写apache-flink程序的时候相信很多新手都遇到下面这样的异常； org.apache.flink.api.common.functions.InvalidTypesException: The return type of function 'main(DemoApp.

Spark Streaming对实时数据流进行分析处理，源源不断的从数据源接收数据切割成一个个时间间隔进行处理；流处理与批处理有明显区别，批处理中的数据有明显的边界、数据规模已知；而流处理数据流并没有边界，也未知数据规模；由于流处理的数据流特征，使之数据流具有不可预测性，而且数据处理

Kafka的消息模型为发布订阅模型，消息生产者将消息发布到主题（topic）中，一个或多个消费者订阅（消费）该主题消息并消费，此模型中发布到topic中的消息会被所有消费者所订阅到，先介绍Kafka消费模型，然后再通过KafkaConsumer原来了解它的业务流程，源码基于kafka 2.4；

　　Kafka Monitor为Kafka的可视化管理与监控工具，为Kafka的稳定运维提供高效、可靠、稳定的保障，这里主要简单介绍Kafka Monitor的相关功能与页面的介绍；　　Kafka Monitor v0.1 主要功能有：Kafka基本信息仪表盘、broker列表、topic列表、当

　　在Kafka中应用了大量的延迟操作但在Kafka中并没用使用JDK自带的Timer或是DelayQueue用于延迟操作，而是使用自己开发的DelayedOperationPurgatory组件用于管理延迟操作，Kafka这类分布式框架有大量延迟操作并且对性能要求及其高，而java.util.T

2025-01-14

AI Agents(智能体)是什么能做什么

LSM-Tree：原理与介绍