flink-connector

streamnative/pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

jeff-zou/flink-connector-redis

Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.

mongo-flink/mongo-flink

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

devlive-community/dameng-connector

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

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

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

coalchan/Mock-Java

A simulation data generator with Java version

dahai1996/flink-connector-lettuce-redis

flink connector for redis,use letturce instead of jedis

nkonev/flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.

jcaberio/sentinel-flink-connector-featurestore

Flink connector for writing data into Amazon SageMaker Feature Store

s2-streamstore/flink-connector-s2

Flink connector for S2