消息队列云原生大数据计算服务 MaxCompute kafka 的相关内容

阿里云文档 2025-06-06

Kafka单表实时同步至ApsaraDB for OceanBase

单表实时同步任务根据来源Kafka指定Topic的内容结构对目的ApsaraDB for OceanBase表结构做初始化，然后将Kafka指定Topic的存量数据同步至ApsaraDB for OceanBase，同时也持续将增量数据实时同步至ApsaraDB for OceanBase。本文为您介绍如何将KafkaTopic数据实时同步至ApsaraDB for OceanBase。

阿里云文档 2025-04-01

如何通过数据集成实时入湖

本文以Kafka实时入湖写入至OSS场景为例，为您介绍如何通过数据集成实时入湖OSS（HUDI）。

阿里云文档 2024-12-19

Hologres实时ETL同步到Kafka

实时ETL同步任务根据来源Hologres表结构对目标Kafka的topic进行初始化，将Hologres数据实时同步至Kafka以供消费。本文为您介绍如何创建Hologres实时ETL同步到Kafka任务。

问答 2024-06-09 来自：开发者社区

消息队列Kafka版Connector功能支持从对象存储和大数据计算服务导入到Kafka吗

阿里云文档 2024-03-22

Apache Kafka Connect远程代码执行漏洞

2023年02月08日，Apache发布了一则安全公告，修复了Apache Kafka中存在的一个反序列化漏洞，漏洞编号为CVE-2023-25194。在攻击者可以控制Apache Kafka Connect客户端的情况下，通过SASL JAAS配置和基于SASL的安全协议，在其上创建或修改连接器，从而触发JNDI代码执行漏洞。

阿里云文档 2024-01-10

配置Kafka开启Ranger权限_EMR on ECS_开源大数据平台 E-MapReduce(EMR)

本文介绍了Kafka如何开启Ranger权限控制，以及Ranger Kafka权限配置说明。

文章 2023-05-24 来自：开发者社区

12.Consumer消费者机制和分区策略12.1.消费者拉取数据机制消费者为什么是从broker中pull数据，而不是broker主动push给消费者呢消费者采用pull方式拉取，从broker的partition获取数据。pull模式则可以根据consumer的消费能力进行自行调节拉取消息的多少，不同的消费者性能不一样。如果broker没有消息，consumer可以配置timeout时间，阻....

文章 2023-05-24 来自：开发者社区

【消息队列】一文搞定大数据消息队列Kafka2

6.Kafka数据存储流程和原理概述6.1.Partitiontopic物理上的分组，一个topic可以分为多个partition，每个partition是一个有序的队列是以文件夹的形式存储在具体Broker本机上6.2.LEO（LogEndOffset）表示每个partition的log最后一条Message的位置6.3.HW（HighWatermark）表示partition各个replic....

文章 2023-05-24 来自：开发者社区

【消息队列】一文搞定大数据消息队列Kafka1

1.JMS+AMQP核心知识1.1.什么是MQ中间件全称MessageQueue，主要是用于程序和程序之间的通信，异步+解耦1.2.使用场景核心应用：解耦：订单系统->物流系统异步：用户注册->发送右键，初始化信息削峰：秒杀、日志处理跨平台、多语言分布式事务、最终一致性RPC调用上下游对接，数据源变动->通知下属1.3.JMS消息服务和和常见核心概念（1）什么是JMSjava消....