云原生大数据计算服务 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-10-14 来自：开发者社区

大数据-103 Spark Streaming Kafka Offset管理详解 Scala自定义Offset

点一下关注吧！！！非常感谢！！持续更新！！！目前已经更新到了： Hadoop（已更完） HDFS（已更完） MapReduce（已更完） Hive（已更完） Flume（已更完） Sqoop（已更完） Zookeeper（已更完） HBase（已更完） Redis （已更完） Kafka（已更完） ...

文章 2024-10-14 来自：开发者社区

大数据-67 Kafka 高级特性分区分配策略 Ranger、RoundRobin、Sticky、自定义分区器

点一下关注吧！！！非常感谢！！持续更新！！！目前已经更新到了：Hadoop（已更完）HDFS（已更完）MapReduce（已更完）Hive（已更完）Flume&...

文章 2024-10-14 来自：开发者社区

大数据-61 Kafka 高级特性消息消费02-主题与分区自定义反序列化拦截器位移提交位移管理重平衡

点一下关注吧！！！非常感谢！！持续更新！！！目前已经更新到了： Hadoop（已更完） HDFS（已更完） MapReduce（已更完） Hive（已更完） Flume（已更完） Sqoop（已更完） Zookeeper（已更完） HBase（已更完） Redis （已更完） Kafka（正在更新…） ...

文章 2024-10-14 来自：开发者社区

大数据-59 Kafka 高级特性消息发送03-自定义拦截器、整体原理剖析

文章 2024-10-13 来自：开发者社区

大数据-58 Kafka 高级特性消息发送02-自定义序列化器、自定义分区器 Java代码实现

点一下关注吧！！！非常感谢！！持续更新！！！目前已经更新到了：Hadoop（已更完）HDFS（已更完）MapReduce（已更完）Hive（已更完）Flume&...

阿里云文档 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