自定义云消息队列 Kafka 版的相关内容

阿里云文档 2024-09-30

如何配置Kafka

本文介绍如何创建、查看、编辑、删除Kafka自定义连接器任务。

阿里云文档 2024-03-12

云消息队列 Kafka 版如何使用自定义权限策略

如果系统权限策略不能满足您的要求，您可以创建自定义权限策略实现最小授权。使用自定义权限策略有助于实现权限的精细化管控，是提升资源访问安全的有效手段。本文介绍云消息队列 Kafka 版使用自定义权限策略的场景和策略示例。

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

阿里云Flink-自定义kafka sink partitioner实践及相关踩坑记录

1. 背景及需求链路：Flink -> sink kafka需求：客户需求根据数据的特征，以自定义的逻辑，将不同的数据写到kafka不同的分区中阿里云官方文档链接：https://help.aliyun.com/zh/flink/developer-reference/kafka-connector?spm=a2c4g.11186623.0.0.bc541be5ucyowS#section....

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

Flink CDC我自定义了一个flink SQL的Kafka分区器，有遇到这个问题的吗？

Flink CDC我自定义了一个flink SQL的Kafka分区器，在写入的时候会报类型转换异常，有遇到这个问题的吗？

阿里云文档 2023-09-03

自定义连接器中Workers的概念及配置_云消息队列 Kafka 版(Kafka)

本文介绍自定义连接器中Workers的概念及配置。

阿里云文档 2023-09-03

Kafka自定义连接器中的基本概念和连接配置_云消息队列 Kafka 版(Kafka)

Kafka自定义连接器可以从Kafka集群中提取数据或将Kafka数据推送到其他系统，本文介绍Kafka自定义连接器中的基本概念和连接配置。

问答 2023-07-25 来自：开发者社区

Flink中自定义的sink 如果kafka 已经发送消息了，这个是ck会不会被认为完成。但是最终？

Flink中自定义的sink 如果kafka 已经发送消息了，这个是ck会不会被认为完成。但是最终这个消息发送失败了？

阿里云文档 2023-05-09

Kafka自定义连接器提供的可观测性能力及错误排查步骤

本文介绍Kafka自定义连接器提供的可观测性能力及错误排查步骤。

文章 2022-11-12 来自：开发者社区

【Flink-FlinkUtils】高级自定义封装工具类实现消费kafka数据保存数据到Redis

一、FlinkKafkaToRedis思考一个问题：flink程序运行的时候，我们可以通过神魔样的形式进行传值？1.写死程序传值2.args[0],程序动态传值ParameterTool parameters = ParameterTool.fromPropertiesFile(args[0]); DataStream<String> lines = FlinkUtils.crea.....