flink-connector 开源项目推荐（26 个）

itinycheng /flink-connector-clickhouse

ClickHouse 的 Flink SQL 连接器。支持 ClickHouseCatalog，并可读写主要数据、地图、数组到 ClickHouse。

streamnative /pulsar-flink

使用 Apache Pulsar 和 Apache Flink 进行弹性数据处理

jeff-zou /flink-connector-redis

基于 Lettuce 的异步 Flink 连接器，支持 SQL join 和 sink、查询缓存与调试。

devlive-community /dameng-connector

Dameng Connector 是一个专门为达梦数据库(DM Database)设计的变更数据捕获(CDC)解决方案。该项目通过扩展 Debezium 和 Flink CDC，实现了对达梦数据库的实时数据变更监控、捕获和处理能力，为数据集成、数据同步、实时分析等场景提供强大支持。

mongo-flink /mongo-flink

A MongoDB connector for Apache Flink prior to 1.16. For Flink 1.16+, please use the official MongoDB connector.

oceanbase /flink-connector-oceanbase

Apache Flink Connectors for OceanBase.

TNG /flink-connector-email

IMAP / SMTP connectors for Apache Flink®

vinted /flink-big-query-connector

Flink connector for BigQuery

mattczyz /flink-orc

Adds ORC support to Flink Streaming File Sink

instaer /flinksql-cdc-app

基于Table/SQL API的轻量级Flink CDC应用

yang69 /flink-connector-redis_2.11

forked from org.apache.bahir:flink-connector-redis_2.11:1.0

Aiven-Open /slack-connector-for-apache-flink

Apache Flink® connector for Slack

BinZoom /flinksql-connector-oss

Flink SQL connector for OSS database

thomas-bouvier /mastodon-flink-connector

Flink connector for the streaming Mastodon API

flowerfine /flink-http-connectors

flink http connectors

pangliang /flink-connector-futuopend

该项目在 GitHub 上没有填写描述

phial3 /flink-connector-http

flink connectors http

yagagagaga /flink-connector-redis

A Flink connector for Redis.

ASKRAJPUT5 /Flink-CEP

This is a basic example to show CEP in flink with kafka

jcaberio /sentinel-flink-connector-featurestore

Flink connector for writing data into Amazon SageMaker Feature Store