阿里云文档 2026-06-05

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

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

阿里云文档 2026-06-03

Flink CDC MySQL整库同步Kafka

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

阿里云文档 2026-05-26

使用社区版Flink将Kafka数据同步至AnalyticDB PostgreSQL版-云原生数据仓库AnalyticDB-阿里云

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

阿里云文档 2026-05-25

使用Flink SQL读取Kafka Protobuf数据-实时计算 Flink版-阿里云

Kafka连接器支持读取Protobuf格式的数据。

阿里云文档 2024-09-12

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

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

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

【Azure 事件中心】使用Apache Flink 连接 Event Hubs 出错 Kafka error: No resolvable bootstrap urls

问题描述 参考Github上 Event Hub的示例代码(Using Apache Flink with Event Hubs for Apache Kafka Ecosystems : https://github.com/Azure/azure-event-hubs-for-kafka/tree/master/tutorials/flink),使用Apache Flink kafk...

【Azure 事件中心】使用Apache Flink 连接 Event Hubs 出错 Kafka error: No resolvable bootstrap urls
文章 2022-06-14 来自:开发者社区

Flink读取Kafka报Error sending fetch request

1.概述近日flinksql作业出现不稳定,查看kafka侧以及flink日志,找到了出现波动时间段附近的日志中有这个信息:org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler [] - [ConsumerclientId=consumer-kafka_alarm_10013-2, groupId=k....

Flink读取Kafka报Error sending fetch request

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注