使用 Kafka 和 MongoDB 进行 Go 异步处理
[图片]在我前面的博客文章 “我的第一个 Go 微服务：使用 MongoDB 和 Docker 多阶段构建” 中，我创建了一个 Go 微服务示例，它发布一个 REST 式的 http 端点，并将从 HTTP POST 中接收到的数据保存到 MongoDB 数据库。在这个示例中，我将数据的保存和 MongoDB 分离，并创建另一个微服务去处理它。我还添加了 Kafka 为消息层服务，这
来自： 社区博客kafka实战演练，欲走大数据之路的台阶打造，通往的必经之路
1.kafka介绍 1.1.主要功能 根据官网的介绍，ApacheKafka是一个分布式流媒体平台，它主要有3种功能： 1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因 2：It lets you store streams of record
来自： 社区博客子账号权限管理_消息_产品文档_帮助与文档-网易云
概述 默认情况下，子账号没有使用Kafak控制台的权限。若要允许子账号操作主账号资源权限，必须创建访问控制策略并将这些策略附加到对应的子账号或群组。策略、群组、子账号等访问控制相关介绍详见："访问控制文档" (https://www.163yun.com/help/documents/61161547863609344)。 子账号权限管理 可授权 Kafka Action 和对应资
来自： 产品文档 - 消息 - KafkaKafka实践、升级和新版本（0.10）特性预研
本文来自于网易云社区 一、消息总线MQ和Kafka （挡在请求的第一线） 1. 几个应用场景 case a：上游系统往下游系统推送消息，而不关心处理结果； case b：一份新数据生成，需要实时保存到数据库，索引系统，统计系统等； case c：调用一个耗时很长的接口，需要在任务完成的时候告知调用方； 这个时候消息总线（Message Queue）就可以发挥作用，它的特长是“解耦”： case
来自： 社区博客Spark Streaming 实时计算在甜橙金融监控系统中的应用及优化
志记录进行实时的指标统计，在生产者一端，我们通过 Flume 将数据存入 Kafka 当中， 而在消费者一端，我们利用 Spark Streaming 从 Kafka 中不断的拉取数据进行指标统计并存入
来自： 社区博客使用示例_消息_产品文档_帮助与文档-网易云
producer 和 consumer 开发实践 前言 消息模型可以分为两种， 队列和发布-订阅式。 队列的处理方式是一组消费者从服务器读取消息，一条消息只有其中的一个消费者来处理。在发布-订阅模型中，消息被广播给所有的消费者，接收到消息的消费者都可以处理此消息。Kafka 为这两种模型提供了单一的消费者抽象模型： 消费者组 （"consumer group" (https://www.163
来自： 产品文档 - 消息 - Kafka产品优势_消息_产品文档_帮助与文档-网易云
产品优势 本文主要介绍 Kafka 作为专业的消息中间件相比其它的 MQ 所具备的优势。 专业 消息领域业内专业的消息中间件，消息保证不丢，技术体系丰富成熟。 可靠性 Kafka 要实现从 producer 到 consumer 之间的可靠的消息传送和分发。传统的 MQ 系统通常都是通过 broker 和 consumer 间的确认（ack）机制实现的，并在 broker 保存消息分发的状态。即
来自： 产品文档 - 消息 - Kafka网易考拉内容管理平台全量ES数据迁移总结
终能够保证数据的正确性、一致性、可用性！ 一、需求分析 最近在做考拉社区内容数据由原先的CMS系统迁移到内容管理平台中，相关的搜索逻辑也有很大的改动，使用原先的ES
来自： 社区博客产品概述_消息_产品文档_帮助与文档-网易云
产品简介 网易云 Kafka 是由网易云提供的高性能、高可靠的分布式消息服务，通过一套独特的设计提供了消息系统中间件的功能。 网易云 Kafka 支持集群弹性伸缩、在线水平扩容，并提供完善的集群、Topic 状态监控查看及性能监测等功能，简化用户的部署和使用。 网易云 Kafka 基于 Apache Kafka 进行二次开发，并完全兼容 Kafka 协议，已有 Apache Kafka 企业和用
来自： 产品文档 - 消息 - Kafka服务等级协议_消息_产品文档_帮助与文档-网易云
服务等级协议 *** 服务范围 网易云Kafka是一种高性能、高可靠的分布式消息服务，支持集群弹性伸缩、在线水平扩容，并提供完善的集群、Topic状态监控查看及性能监测等功能，简化用户的部署和使用，使您能专注于应用开发和业务发展。 服务等级指标 服务可用性 服务可用性不低于99.95 %。 可用性计算公式为：单个集群实例每个月服务可用时间/（单个集群实例每个月服务不可用时间+单个集群实例每个月服
来自： 产品文档 - 消息 - Kafka
