flink-connector-pulsar
data pipeline connector
A connector for streaming data from a distributed messaging system to Apache Flink
Apache flink
53 stars
33 watching
63 forks
Language: Java
last commit: 5 months ago connectordatastreamflinkpulsarsqltable
Related projects:
| Repository | Description | Stars |
|---|---|---|
| apache/flink-connector-opensearch | Connects Flink data streams to OpenSearch for indexing and querying | 23 |
| apache/flink-connector-aws | Provides connectivity between Apache Flink and Amazon Web Services (AWS) for real-time data processing | 60 |
| apache/flink-connector-jdbc | A Java-based connector for connecting Apache Flink to relational databases via JDBC. | 127 |
| apache/flink-connector-hbase | A connector for integrating HBase with the Apache Flink stream processing framework | 30 |
| apache/flink-connector-rabbitmq | A Flink connector for RabbitMQ message broker | 19 |
| apache/flink-connector-prometheus | A Java-based connector for integrating Prometheus data into Apache Flink stream processing applications | 9 |
| apache/flink-connector-gcp-pubsub | A Java-based connector for integrating Google Cloud PubSub with Apache Flink's data processing framework | 11 |
| apache/rocketmq-connect | A tool for streaming data between Apache RocketMQ and other systems | 122 |
 snowflakedb/snowflake-kafka-connector | A plugin that enables data ingestion from Kafka topics to Snowflake tables | 141 |
| apache/hbase-connectors | Connects Apache HBase with other systems like Kafka and Spark for data processing and integration. | 236 |
 jueshancoder/pulsar-io-tdengine | Connects Pulsar to TDengine data storage | 3 |
| apache/pulsar-client-node | A Node.js client library for interacting with Pulsar, a pub/sub messaging system. | 148 |
| apache/pulsar-dotpulsar | A .NET client library for Apache Pulsar message broker | 238 |
| apache/pulsar-adapters | This repository provides adapters for integrating various messaging and streaming technologies with Apache Pulsar | 24 |
 liuyq-617/td-spark | A Java project that reads from and writes to TDengine using Apache Spark. | 0 |