阿里云文档 2025-01-27

MySQL整库同步Kafka

本文为您介绍如何将MySQL整库同步Kafka,从而降低多个任务对MySQL数据库造成的压力。

阿里云文档 2024-10-09

如何创建和使用Kafka JSON Catalog

配置Kafka JSON Catalog后,您可以在Flink全托管作业开发中直接访问Kafka集群中格式为JSON的Topic,无需再定义Schema。本文为您介绍如何在Flink全托管模式下创建、查看及删除Kafka JSON Catalog。

阿里云文档 2024-09-26

如何使用UpsertKafka连接器,有哪些使用限制/语法结构/参数和示例

本文为您介绍如何使用Upsert Kafka连接器。

阿里云文档 2024-09-12

使用Kafka连接器进行Kerberos身份认证

Kerberos是一种网络身份验证协议,用于提供安全的身份验证服务,以保证通信的安全性。只有在Flink开发控制台正确配置Kerberos和Kafka服务的信息,Flink作业才能访问开启Kerberos认证服务的Kafka集群。本文为您介绍如何为Kafka客户端开启Kerberos认证。

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

Flink与Kafka的终极联盟:揭秘如何在一瞬间切换SASL机制,保护您的数据不受黑客侵袭!

Apache Flink是一个高性能、高可用的流处理框架,广泛应用于实时数据处理和分析场景。在与Kafka集成时,确保数据的安全性是至关重要的。安全认证层(SASL)为Kafka通信提供了一种安全的机制,可以防止未经授权的访问。本文将探讨如何在Flink中配置KafkaConsumer以使用两种不同的SASL机制:...

问答 2024-06-01 来自:开发者社区

Flink支持kafka SASL访问kafka吗

Flink支持kafka SASL访问kafka吗

阿里云文档 2023-05-06

如何通过社区版Flink将Kafka的数据同步至AnalyticDBPostgreSQL

本文介绍如何通过社区版Flink将Kafka的数据同步至AnalyticDB PostgreSQL版。

问答 2022-12-20 来自:开发者社区

Flink配置消息队列Kafka源表时,Kafka集群需要SASL(Simple Authentic

Flink配置消息队列Kafka源表时,Kafka集群需要SASL(Simple Authentication and Security Layer)认证,此时DDL with参数应该怎么配置

问答 2022-06-22 来自:开发者社区

话说,请问大佬们,flink kafka sink 是不是不支持 auth 呀?使用 SASL/PL

话说,请问大佬们,flink kafka sink 是不是不支持 auth 呀?使用 SASL/PLAIN 认证各种报错

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等