云消息队列 Kafka 版异步同步的相关内容

阿里云文档 2024-09-30

如何将PolarDB-X 1.0同步至阿里云消息队列Kafka

本文介绍如何使用数据传输服务DTS（Data Transmission Service）将PolarDB-X 1.0同步至阿里云消息队列Kafka。

阿里云文档 2024-09-30

将PolarDB PostgreSQL版（兼容Oracle）同步到Kafka

本文介绍如何使用数据传输服务DTS（Data Transmission Service），将PolarDB PostgreSQL版（兼容Oracle）集群的数据同步至阿里云消息队列Kafka版。

阿里云文档 2024-07-08

Hologres实时ETL同步到Kafka

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

阿里云文档 2024-06-27

如何创建Kafka实时ETL同步至Hologres任务

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

文章 2024-01-03 来自：开发者社区

Kafka - 异步/同步发送API

异步发送普通异步发送需求：创建Kafka生产者，采用异步的方式发送到Kafka broker异步发送流程Code <dependency> <groupId>org.apache.kafka</gro...

阿里云文档 2023-09-06

如何将RDSMySQL同步至阿里云消息队列Kafka版

数据传输服务DTS（Data Transmission Service）支持RDS MySQL实例同步至阿里云消息队列Kafka版。

文章 2023-08-04 来自：开发者社区

Kafka学习---2、kafka生产者、异步和同步发送API、分区、生产经验(二）

3、案例二没有指明 partition 值但有 key 的情况下，将 key 的 hash 值与 topic 的 partition 数进行取余得到 partition 值。package org.zhm.producer; import org.apache.kafka.clients.producer.*; import org.apache.kafka.common.ser...

文章 2023-08-04 来自：开发者社区

Kafka学习---2、kafka生产者、异步和同步发送API、分区、生产经验(一）

1、kafka生产者1.1 生产者消息发送流程1.1.1 发送原理在消息发生的过程中，设计到了两个线程——main线程和Sender线程。在main线程中创建了一个双端队列RecordAccumulator。main线程将消息发给RecordAccumulator，Sender线程不断从RecordAccumulator中拉取消息发送到Kafka Broker。bat...