后端-RabbitMQ
RabbitMQ是一种基于AMQP协议的消息队列中间件，支持异步消息传递。AMQP协议定义了Broker、Virtual host、Connection、Channel、Exchange、Queue等...
基于Spring Kafka实现火山云Kafka SASL_PLAINTEXT认证的完整指南
本文详细介绍了如何使用Spring Kafka实现与火山云Kafka服务的SASL_PLAINTEXT认证连接，涵盖了从基础配置到高级特性的完整内容。通过多种测试方案，开发者可以快速验证和集成Kafk...
Java 大视界 — Java 大数据在智能交通智能公交系统优化与乘客出行服务提升中的应用（409）
摘要 本文探讨了Java大数据技术在智能公交系统优化中的应用。针对传统公交系统存在的发班不合理、实时定位缺失、调度滞后及数据孤岛等问题，作者团队采用Flink+HBase+Spring Boot技术栈...
Hive下载与安装
Hive直连数据库式和远程服务模式的傻瓜式教程
【Kafka】与【Hadoop】的集成应用案例深度解析
本文深入探讨了Kafka与Hadoop两大大数据处理技术的集成应用案例。首先，文章概述了Kafka作为分布式流处理平台的优势，包括其高吞吐量、低延迟以及强大的容错能力，这些特性使其成为处理实时数据流的...
实时知识增强大模型：基于Flink的流式向量索引与动态RAG系统
本文提出了一种面向大模型应用的实时数据流处理架构，通过FlinkCDC+Milvus增量索引+动态Prompt注入技术，实现知识库分钟级更新与毫秒级查询。该架构创新性地采用时间感知向量编码与热点数据预...
01 | 数据仓库主题域如何划分
主题域是面向业务分析、围绕某一核心业务过程或对象组织起来的数据集合，代表企业中一个相对独立、稳定的业务领域。主题域划分的本质，是将混沌的原始数据，转化为结构化的业务语言。✅好的主题域划分应做到业务人员...
Spring Cloud Stream：消息驱动微服务的实战与 Kafka 集成终极指南
摘要： Spring Cloud Stream（SCS）通过消息驱动解耦微服务，解决同步调用的性能瓶颈与雪崩效应。其核心Binder机制屏蔽Kafka等中间件差异，支持函数式编程简化配置。关键实践包括...
Java 大视界 — Java 大数据在智能医疗健康档案数据分析与个性化健康管理中的应用（410）
本文基于 2023 年 6 月省级智能医疗健康档案项目（覆盖 380 万糖尿病患者），详解 Java 大数据（Flink 1.15.2+HBase 2.4.17+Spark 3.3.0）在健康档案数据...
2025年5大数据连接器深度测评：从云端到本地，哪款是你的增长利器？
对于希望快速实现业务增长，赋能一线员工进行自助分析决策的消费和零售企业，像观远数据这样的一站式智能分析平台，将数据连接与业务分析紧密结合，可能是更高效的选择。对于需要进行复杂数据治理和主数据管理的大型...