简介：咱们在几年前决定引入 MQ 时，市场上曾经有不少成熟的解决方案，比方 RabbitMQ , ActiveMQ，NSQ，Kafka 等。思考到稳定性、保护老本、公司技术栈等因素，咱们抉择了 RocketMQ。

简介：在 1.13 中，针对流批一体的指标，Flink 优化了大规模作业调度以及批执行模式下网络 Shuffle 的性能，以及在 DataStream API 方面欠缺无限流作业的退出语义。本文由社区志愿者苗文婷整顿，内容起源自阿里巴巴技术专家高赟(云骞) 在 5 月 22 日北京站 Flink Meetup 分享的《面向流批一体的 Flink 运行时与 DataStre…

QoS 0 – 最多散发一次当 QoS 为 0 时，音讯的散发依赖于底层网络的能力。发布者只会公布一次音讯，接收者不会应答音讯，发布者也不会贮存和重发消息。音讯在这个等级下具备最高的传输效率，但可能送达一次也可能基本没送达。

消息中间件(未完待续)作用解耦合（生产、生产隔离开）削峰填谷（异步化）Kafka次要用于解决沉闷的流式数据,大数据量的数据处理上。RabbitMQ应用AMQP协定的消息中间件。独立部署，可做队列、PubSub模式。亦可实现延时队列以实现非凡业务场景。MQTT实用物联网等网络不稳固、大量数据传输。头小，仅需2byteQOS 0、1、2别离…

简介：Matrix 通过一年多的建设，目前已具备多渠道对立接入、第三方生态互联互通、基金特色交易场景化封装等性能个性。Matrix 通过建设有品质、有温度的陪伴，从技术上和体验上，让用户了解危险，了解投资，进而为客户继续发明价值。

简介：随着公司业务的一直倒退，流量也在一直增长。咱们发现生产中的一些重大事故，往往是被突发的流量冲跨的，对流量的治理和防护，保障系统高可用就尤为重要。

阿里云EMR服务Kafka和Hadoop平安集群应用Kerberos进行用户平安认证，通过ApacheRanger服务进行拜访受权治理。本最佳实际中以ApacheWeb服务器日志为例，演示基于Kafka和Hadoop的生态组件构建日志大数据仓库，并介绍在整个数据流程中，如何通过Kerberos和Ranger进行认证和受权的相干配置。

Quick Audience 数据可视化剖析平台定位智能用户增长，实现全方位洞察，多渠道触达的增长闭环，实现以人为核心的消费者全生命周期洞察经营。

导读：整个机器学习的过程，从数据上报、到特色计算、到模型训练、再到线上部署、最终成果评估，整个流程十分简短。在 b 站，多个团队都会搭建本人的机器学习链路，来实现各自的机器学习需要，工程效率和数据品质都难以保障。于是咱们基于 Flink 社区的 aiflow 我的项目，构建了整套机器学习的规范工作流平台，减速机器学习…

简介：Flink+Hologres亿级用户实时UV准确去重最佳实际UV、PV计算，因为业务需要不同，通常会分为两种场景：离线计算场景：以T+1为主，计算历史数据实时计算场景：实时计算日常新增的数据，对用户标签去重针对离线计算场景，Hologres基于RoaringBitmap，提供超高基数的UV计算，只需进行一次最细粒度的预聚合计算，也只生…