文章 2024-08-22 来自:开发者社区

Kafka生产者同步和异步的JavaAPI代码演示

生产者API文档 http://kafka.apache.org/10/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html. 版本说明 Kafka 0.10.0.0 及以后的版本,对生产者代码的底层实现进行了重构。 katka.producer.Producer类...

Kafka生产者同步和异步的JavaAPI代码演示
问答 2024-08-14 来自:开发者社区

Flink在使用ctas中,能否指定比如kafka的元信息不同步?

Flink在使用ctas中,能否指定比如kafka的元信息不同步,kafka的key不同步之类的功能呢?

问答 2024-08-14 来自:开发者社区

大数据计算MaxCompute在odps上有一个kafka同步到es的离线任务 任务是这么配置的?

大数据计算MaxCompute在odps上有一个kafka同步到es的离线任务 任务是这么配置的 但是同步数据报错,kafka中一直有数据在产出 报错信息?

问答 2024-08-13 来自:开发者社区

DataWorks在odps上有一个kafka同步到es的离线任务 任务是这么配置的 ?

DataWorks在odps上有一个kafka同步到es的离线任务 任务是这么配置的 但是同步数据报错,kafka中一直有数据在产出 报错信息? https://dataworks.data.aliyun.com/cn-hangzhou/workbench?defaultProjectId=54275&env=prod&taskId=6926293231&userProje...

问答 2024-07-29 来自:开发者社区

dts支持多个polardb mysql的数据表,增量同步投递到同一个kafka topic吗?

dts支持多个polardb mysql的实例相同结构的数据表,增量同步投递到同一个kafka topic吗?

文章 2024-07-24 来自:开发者社区

什么是Kafka的Rebalance,什么情况下会发生Rebalance

问题一:Kafka的副本消息同步是如何进行的? Kafka的副本消息同步是如何进行的? 参考回答: Kafka的副本消息同步过程包括:Follower发送FETCH请求给Leader;Leader读取底层日志文件中的消息数据,并更新内存中Follower副本的LEO(Log End Offset)值;接着,Leader尝试更新分区高水位值(HW);Fo...

问答 2024-07-23 来自:开发者社区

DataWorks这个kafka的读的同步任务呀。我不选重置位点他是接着上一轮消费的位置继续消费吗?

DataWorks这个kafka的读的同步任务呀。上一轮我跑完然后停止了。我再次启动,我不选重置位点,他是接着上一轮消费的位置继续消费把?

文章 2024-07-17 来自:开发者社区

DataWorks产品使用合集之如何离线增量同步Kafka数据,并指定时间范围进行同步

问题一:dataworks为什么在Datastudio中看不到odps sql的新建节点菜单? dataworks为什么在Datastudio中看不到odps sql的新建节点菜单? 参考回答: https://help.aliyun.com/zh/dataworks/user-guide/create-a-maxcompute-data-source...

DataWorks产品使用合集之如何离线增量同步Kafka数据,并指定时间范围进行同步
问答 2024-07-17 来自:开发者社区

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?mysql -> flink cdc -> kafka -> flink -> sr 这个样子的

问答 2024-07-15 来自:开发者社区

在Flink CDC中MySQL 整库同步 Kafka,不支持动态加表功能吗?

在Flink CDC中MySQL 整库同步 Kafka,不支持动态加表功能吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注