1
条回答
写回答
写回答
-
推荐回答近10多年来，诸如KV存储（HBase）、搜索（Elasticsearch）、流式处理（Storm、Spark、Samza）、时序数据库（OpenTSDB）等专用系统应运而生。这些系统是为单一的目标而产生的，因其简单性使得在商业硬件上构建分布式系统变得更加容易且性价比更高。普遍场景下同一份数据集可能需要被注入到多个专用系统内。例如，当应用日志用于离线日志分析时，搜索单个日志记录同样不可或缺，而构建各自独立的工作流来采集每种类型的数据再导入到各自的专用系统显然不切实际，这个时候利用消息队列Kafka版作为数据中转枢纽将成为一个不错的解决方案，同一份数据可以被导入到不同专用系统中。根据需要注入数据的系统建立消费者组，通过多个消费者组订阅一个topic的方式来实现将一份数据注入到不同的消费者系统。对于数据的生产端而言则无需为每个系统独立采集数据，只需要将一份数据导入到对应的topic中即可。
以上内容摘自《企业级云原生白皮书项目实战》电子书，点击https://developer.aliyun.com/ebook/download/7774可下载完整版
2022-10-17 17:44:10赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
为什么mqtt 连接一直显示 Not authorized to connect ？用的官网示例。
1816
请教下 mqtt连接成功了，能收到消息， 后面又自动断开了连接， 是什么情况？
605
在Apache RocketMQ中这种情况队列数量应该设置多少比较合理呢？
554
rocketmq客户端日志路径/root/logs/rocketmqlogs，怎么修改或者关闭日志?
1050
客户端会产生很多rocketmq日志，咋办？如何关闭？
209
Apache RocketMQ中consumeThreadMax 消费者最大线程数怎么理解？ 如果
1042
消息队列 MQClientException: Send [3] times, still failed
10478
rocketmq发送延迟消息第一条会报错
470
rocketmq5.x版本删除消息怎么搞，除了定时清理过期消息机制？
1115
大佬们，问个问题：rocketmqListener如何selectorexpression动态设置？
467
展开全部
什么是消息队列？
12773
Redis笔记（七）Java实现Redis消息队列
8087
阿里云即将直播发布消息队列Kafka：全面融合开源生态
5315
如何使用phpMQTT连接阿里云微服务消息队列for IoT
4542
网易云音乐的消息队列改造之路
4255
RabbitMQ消息队列（四）：分发到多Consumer（Publish/Subscribe）
3114
阿里云消息队列 Kafka 公测发布
1967
KiteQ —— 基于 go + protobuff 的消息队列
1870
突破Java面试(9)-如何保证消息队列的顺序性
3152
消息队列常见的 5 个应用场景
3429
展开全部
