Git Product home page Git Product logo

pulsar-hub's Introduction

StreamNative Hub

StreamNative Hub is an online service for finding, reviewing, and downloading extensions for the Apache Pulsar ecosystem. It highlights features, richer component descriptions, links to external resources for the components, and installation and support information.

The StreamNative Hub currently hosts the following extensions for Pulsar ecosystem.

  • Connectors (source & sink)
  • Offloaders
  • Protocol handlers
  • Authentication plugins
  • Integrations with data processing engines
  • Interceptors
  • ... and more

How to add your plugins

If a new plugin is introduced, you should upload the plugin to the target category. Currently, the StreamNative supports the following categories for the plugin.

  • Authentication
  • Connector
  • Data processing
  • Deployment
  • Handler
  • Logging
  • Monitoring
  • Offloader

If a new category is required, you can create it. For details about how to create a new category, see create new category.

Prepare for uploading plugin

This section describes operations to be performed before creating a PR (Pull Request) for a plugin.

  • Clone the pulsar-hub repository to the local.
  • Create a sub-folder under the cloned pulsar-hub repository and put the document in this sub-folder. The sub-folder name is set to the version of the plugin to be submitted, such as 2.5.1.
  • Put the plugin image in the image folder under the cloned pulsar-hub repository.

Create new category

To create a new category, follow these steps:

  1. Create a branch based on the latest pulsar-hub master repository.
  2. Create a sub-folder under the pulsar-hub folder in the local. Set the name of the sub-folder to the category name with lower cases. If the category name consists of multiple words, use the hyphen (-) between these words, such as data-processing.

Create plugin document

To create a document for a new plugin, follow these steps:

  1. Create a branch based on the latest pulsar-hub master repository.
  2. Create a document in the target folder for the plugin. For the document template about the plugin, see plugin document template.
  3. Commit your updates, create a PR, and then publish the PR to the pulsar-hub master repository.
  4. Update comments, if any.
  5. If no more comment, ask reviewers to approve the PR and merge the PR to the master.

Plugin document template

This section describes a plugin document structure, including the following two parts:

  • Metadata
  • Body text

Metadata

The metadata of a plugin consists of the following fields:

description:
author: 
contributors: 
language: 
document:
source: 
license: 
tags: 
alias: 
features:
license_link: 
icon: 
download: 
support:
support_link:
support_image:
dockerfile:
owner_name:
owner_img:
id: 

The following table describes tags covered in the metadata of a plugin.

Item Description
description It is a short description about the plugin.
author Set the name of the author for the plugin.
  • Use square brackets ([]) and double quotation marks ("") to wrap the author name, such as ["ASF"].
  • If there are multiple authors, use a comma to separate them, such as ["StreamNative", "Huanli Meng"].
  • contributors Set the name of the contributor for the plugin.
  • Use square brackets ([]) and double quotation marks ("") to wrap the contributor name, such as ["ASF"].
  • If there are multiple contributors, use a comma to separate them, such as ["StreamNative", "Huanli Meng"].
  • language Set the language used by the plugin.
    document At present, leave this blank.
    source Set the source link address for the plugin. It is the root directory of the source code of the plugin. Use double quotation marks ("") to wrap the link address of the source, such as "https://github.com/apache/pulsar/tree/v2.3.2/pulsar-io/hdfs3".
    license By default, it is set to Apache License 2.0.
    tags Set keywords for this document.
  • Use square brackets ([]) and double quotation marks ("") to wrap the keywords.
  • If there are multiple keywords, use a comma to separate them, such as ["OpenTracing", "Jaeger", "Monitoring"].
  • alias It is the name displayed on the StreamNative website. The alias is case sensitive.
    features Describe what the plugin is used to do. Use double quotation marks ("") to wrap the download link of the NAR package of the plugin.
    license_link Set the license link of the plugin. Use double quotation marks ("") to wrap the license link of the plugin.
    icon Set the image link for the plugin. If there is no image available, leave this blank.
    download Set the download link for a NAR package of the plugin. Use double quotation marks ("") to wrap the download link of the NAR package of the plugin.
    support Set the support organization of the plugin.
    support_link Set the link of the support organization.
    support_image Set the image logo of support organization.
    dockerfile At present, leave this blank.
    owner_name Set the owner of the component. This is optional. By default, it is set to Apache Software Foundation.
    owner_img Set the picture of the component owner, this is optional, default /images/apache-powered-by.svg
    id By default, it is set to the file name of the plugin (without extension).
  • Use lower cases. Use double quotation marks ("") to wrap the ID.
  • Use hyphens (-) between words if the ID consists of multiple words, such as "open-tracing-client".
  • Body text

    In general, the body text of a plugin document includes the following sections:

    • Overview
    • Installation
      • Prerequisites
      • Procedures
    • Configuration
      • XXX configuration (XXX refers to the plugin name.)
      • Configure XXX (XXX refers to the plugin name.)
    • Usage
    • Monitoring (Optional)
    • Security (Optional)
    • Metrics (Optional)
    • How it works (Optional)
    • Reference (Optional)
    • Troubleshooting (Optional)
    • Tutorial (Optional)
    ### Overview
    
    > Describe what the plugin is used for.
    
    ### Installation
    
    > Describe how to install or load the plugin.
    
    #### Prerequisites
    
    > List prerequisite used for installing the plugin, if any.
    
    #### Procedures
    
    > Lists how to instal the plugin.
    
    ### Configuration
    
    > List some configuration examples to describe what the plugin can be used to do.
    
    #### XXX configuration
    
    > List configuration items available for the plugin. XXX refers to the plugin name.
    
    #### Configure XXX
    
    > How to configure the plugin through Json or Yaml file. XXX refers to the plugin name.
    
    ### Usage
    
    > Provide an example to describe what the connector can be used to do.
    
    ### Monitoring (Optional)
    
    > Describe how to monitor the plugin.
    
    ### Security (Optional)
    
    > List security configurations required to be configured and how to configure it.
    
    ### Metrics (Optional)
    
    > List metrics available for the plugin.
    
    ### How it works (Optional)
    
    > List basic principles for the plugin to work.
    
    ### Reference (Optional)
    
    > List additional external references, if any.
    
    ### Troubleshooting (Optional)
    
    > List FAQs and how to troubleshoot the bugs, if any.
    
    ### Tutorial (Optional)
    
    > List a step-by-step for the whole process.

    pulsar-hub's People

    Contributors

    anonymitaet avatar danpi avatar gaoran10 avatar github-actions[bot] avatar huanli-meng avatar illegalnumbers avatar imaffe avatar jiangpengcheng avatar jiazhai avatar nlu90 avatar robertindie avatar shibd avatar sijia-w avatar sijie avatar streamnativebot avatar tuteng avatar urfreespace avatar wolfstudy avatar yaalsn avatar yjshen avatar zymap avatar

    Stargazers

     avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

    Watchers

     avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

    pulsar-hub's Issues

    Review for doc `aws-s3.md`

    Some Suggestions About AWS-S3 Doc

    1. Prerequisite

    This is AWS S3 doc, maybe we could don't care about Filesystem.

    1. Copy the Pulsar offloaders as offloaders in the Pulsar directory.

    We only need the tiered-storage-jcloud-2.5.1.nar.

    1. Set the environment variables AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY in conf/pulsar_env.s.

    The conf file name is pulsar_env.sh.

    1. modify ledge to ledger.

    The offloading operation starts after a ledge rollover is triggered. To ensure offload data successfully, it is recommended that you wait until several ledge rollovers are triggered. In this case, you might need to wait for a second. You can check the ledge status using pulsar-admin.

    1. Whether we need to add introduce about namespace offload policies in this doc.

    The namespace offload policies is a common config for cloud storage and filesystem storage.

    Add hdfs2 sink metadata

         "name": "hdfs2-sink",
          "description": "The HDFS2 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files.",
          "author": "david-streamlio",
          "contributors": "david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-hdfs2-sink/'>This guide</a> explains how to configure and use the HDFS2 sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-hdfs2-sink/'>HDFS2 Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, HDFS2, Sink",
          "alias": "HDFS2 Sink",
          "features": "Sync data of pulsar topic to HDFS2",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-hdfs2-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add influxdb sink metadata

          "name": "influxdb-sink",
          "description": "The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB.",
          "author": "murong00",
          "contributors": "murong00",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-influxdb-sink/'>This guide</a> explains how to configure and use the InfluxDB sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-influxdb-sink/'>InfluxDB Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, InfluxDB, Sink",
          "alias": "InfluxDB Sink",
          "features": "Sync data of pulsar topic to InfluxDB",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-influxdb-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add hbase sink metadata

          "name": "hbase-sink",
          "description": "The hbase Sink Connector is used to pull messages from Pulsar topics and persist the messages to a hbase table.",
          "author": "ambition119",
          "contributors": "ambition119",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-hbase/'>This guide</a> explains how to configure and use the Hbase sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-hbase/'>Hbase Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Hbase, Sink",
          "alias": "Hbase Sink",
          "features": "Sync data of pulsar topic to Hbase",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-hbase-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add kinesis sink metadata

          "name": "kinesis-sink",
          "description": "The Kinesis sink connector pulls data from Pulsar and persists data into Amazon Kinesis.",
          "author": "david-streamlio",
          "contributors": "addisonj,david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-kinesis-sink/'>This guide</a> explains how to configure and use the Kinesis sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-kinesis-sink/'>Kinesis Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Kinesis, Sink",
          "alias": "Kinesis Sink",
          "features": "Sync data of pulsar topic to Kinesis",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-kinesis-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    [Doc] Add Kafka source connector doc to Pulsar Registry repo

          "name": "kafka-source",
          "description": "The Kafka source connector pulls messages from Kafka topics and persists the messages to Pulsar topics.",
          "author": "murong00",
          "contributors": "murong00,lucperkins,liketic,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-kafka-source/'>This guide</a> explains how to configure and use the Kafka source connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-kafka-source/'>Kafka Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Kafka, Pulsar IO, Source",
          "alias": "Kafka Source",
          "features": "Sync Kafka data to pulsar topic",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-kafka-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add mongodb sink metadata

          "name": "mongodb-sink",
          "description": "The MongoDB sink connector pulls messages from Pulsar topics and persists the messages to collections.",
          "author": "merlimat",
          "contributors": "merlimat,bbonnin",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-mongo-sink/'>This guide</a> explains how to configure and use the MongoDB sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-mongo-sink/'>MongoDB Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, MongoDB, Sink",
          "alias": "MongoDB Sink",
          "features": "Sync data of pulsar topic to MongoDB",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-mongo-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add netty source metadata

        "name": "netty-source",
          "description": "The Netty source connector opens a port that accepts incoming data via the configured network protocol and publish it to user-defined Pulsar topics.",
          "author": "ambition119",
          "contributors": "david-streamlio,ambition119",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-netty/'>This guide</a> explains how to configure and use the Netty source connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-netty/'>Netty Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Netty, Source",
          "alias": "Netty Source",
          "features": "Sync Netty data to pulsar topic",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-netty-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add kinesis source metadata

          "name": "kinesis-source",
          "description": "The Kinesis source connector pulls data from Amazon Kinesis and persists data into Pulsar.",
          "author": "david-streamlio",
          "contributors": "addisonj,david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-kinesis-source/'>This guide</a> explains how to configure and use the Kinesis source connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-kinesis-source/'>Kinesis Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Kinesis, Source",
          "alias": "Kinesis Source",
          "features": "Sync Kinesis data to pulsar topic",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-kinesis-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add solr sink metadata

          "name": "solr-sink",
          "description": "The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.",
          "author": "murong00",
          "contributors": "murong00",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-solr-sink/'>This guide</a> explains how to configure and use the Solr sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-solr-sink/'>Solr Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Solr, Sink",
          "alias": "Solr Sink",
          "features": "Sync data of puslar topic to Solr",
          "icon": "/images/connector.png",
          "download": "#",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add elasticsearch sink metadata

          "name": "elasticsearch-sink",
          "description": "The ElasticSearch sink connector pulls messages from Pulsar topics and persists the messages to indexes.",
          "author": "srkukarni",
          "contributors": "srkukarni,david-streamlio,geraudster,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-elasticsearch-sink/'>This guide</a> explains how to configure and use the ElasticSearch sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-elasticsearch-sink/'>ElasticSearch Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, ElasticSearch, Sink",
          "alias": "ElasticSearch Sink",
          "features": "Sync data of pulsar topic ElasticSearch",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-elastic-search-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add flume sink metadata

          "name": "flume-sink",
          "description": "The Flume sink connector pulls messages from Pulsar topics to logs.",
          "author": "tuteng",
          "contributors": "tuteng",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-flume-sink/'>This guide</a> explains how to configure and use the Flume sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-flume-sink/'>Flume Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Flume, Sink",
          "alias": "Flume Sink",
          "features": "Sync data of pulsar topic Flume",
          "icon": "/images/connector.png",
          "download": "#",
          "support": "Apache community",
          "supported_org": "Apache"
    

    [Doc] Add Flume source connector doc to Pulsar Registry repo

    Refer to:

          "name": "flume-source",
          "description": "The Flume source connector pulls messages from logs to Pulsar topics.",
          "author": "tuteng",
          "contributors": "tuteng",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-flume-source/'>Document</a>",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-flume-source/'>File Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Flume, Source",
          "alias": "Flume Source",
          "features": "Sync log data to pulsar topics",
          "icon": "/images/connector.png",
          "download": "#",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add redis sink metadata

          "name": "redis-sink",
          "description": "The Redis sink connector pulls messages from Pulsar topics and persists the messages to a Redis database.",
          "author": "murong00",
          "contributors": "murong00,srkukarni",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-redis-sink/'>This guide</a> explains how to configure and use the Redis sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-redis-sink/'>Redis Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Redis, Sink",
          "alias": "Redis Sink",
          "features": "Sync data of puslar topic to Redis",
          "icon": "/images/connector.png",
          "download": "#",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add kafka sink metadata

          "name": "kafka-sink",
          "description": "The Kafka sink connector pulls messages from Kafka topics and persists the messages to Pulsar topics.",
          "author": "murong00",
          "contributors": "murong00,lucperkins,liketic,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-kafka-sink/'>This guide</a> explains how to configure and use the Kafka sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-kafka-sink/'>Kafka Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Kafka, Pulsar IO, Sink",
          "alias": "Kafka Sink",
          "features": "Sync of pulsar topic to Kafka",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-kafka-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    [CI] CI can not work when the PR is from a fork

    Description

    Because the CI is from a private repository, we need to use a token to checkout to the repository then run the private action. But it doesn't work when the PR is opened from a fork. Because the fork hasn't the required token for accessing the private CI repo.

    Add aerosipike sink metadata

          "name": "aerospike-sink",
          "description": "The Aerospike sink connector pulls messages from Pulsar topics to Aerospike clusters.",
          "author": "merlimat",
          "contributors": "merlimat,aahmed-se,srkukarni,jerrypeng,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-aerospike-sink/'>This guide</a> explains how to configure and use the Aerospike sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-aerospike-sink/'>Aerospike sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Aerospike, Sink",
          "alias": "Aerospike sink",
          "features": "Sync pulsar topic data to Aerospike",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-aerospike-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
     
    

    [Doc] Add Canal source connector doc to Pulsar Registry repo

    Refer to:

    {
          "name": "canal-source",
          "description": "The Canal source connector pulls messages from MySQL to Pulsar topics.",
          "author": "tuteng",
          "contributors": "tuteng",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-cdc-canal/'>This guide</a> explains how to congifure and use Canal source connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-cdc-canal/'>Canal Document</a>",
          "licensing": "Apache-2.0",
          "tags": "Pulsar IO, Canal, MySQL, Source",
          "alias": "Canal Source",
          "features": "Use Canal sync data",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-canal-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
        }
    

    [Doc] Add Twitter Firehose source connector doc to Pulsar Registry repo

          "name": "twitter-firehose-source",
          "description": "The Twitter Firehose source connector receives tweets from Twitter Firehose and writes the tweets to Pulsar topics.",
          "author": "david-streamlio",
          "contributors": "srkukarni,merlimat,jerrypeng,lucperkins,sijie,david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-twitter-source/'>Twitter firehose source</a>",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-twitter-source/'>Twitter Fire Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Twitter Firehose, Pulsar IO, Source",
          "alias": "Twitter FireHose Source",
          "features": "Sync firehose data to pulsar topic",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-twitter-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add hdfs3 sink metadata

          "name": "hdfs3-sink",
          "description": "The HDFS3 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files.",
          "author": "david-streamlio",
          "contributors": "david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-hdfs3-sink/'>This guide</a> explains how to configure and use the HDFS3 sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-hdfs3-sink/'>HDFS3 Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, HDFS3, Sink",
          "alias": "HDFS3 Sink",
          "features": "Sync data of pulsar topic to HDFS3",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-hdfs3-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add cassandra sink metadata

          "name": "cassandra-sink",
          "description": "The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters.",
          "author": "merlimat",
          "contributors": "merlimat,srkukarni,jerrypeng,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-cassandra-sink/'>This guide</a> explains how to configure and use the Cassandra sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-cassandra-sink/'>Cassandra Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, Cassandra, Sink",
          "alias": "Cassandra Sink",
          "features": "Sync pulsar topic data to Cassandra",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-cassandra-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add rabbitmq source metadata

          "name": "rabbitmq-source",
          "description": "The RabbitMQ source connector receives messages from RabbitMQ clusters and writes messages to Pulsar topics.",
          "author": "murong00",
          "contributors": "murong00,merlimat,jerrypeng,srkukarini,lucperkins,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-rabbitmq/'>This guide</a> explains how to configure and use the RabbitMQ source connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-rabbitmq/'>RabbitMQ Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, RabbitMQ, Source",
          "alias": "RabbitMQ Source",
          "features": "Sync RabbitMQ data to pulsar topic",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-rabbitmq-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add rabbitmq sink metadata

          "name": "rabbitmq-sink",
          "description": "The RabbitMQ sink connector pulls messages from Pulsar topics and persist the messages to RabbitMQ queues.",
          "author": "murong00",
          "contributors": "murong00,merlimat,jerrypeng,srkukarini,lucperkins,sijie",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-rabbitmq-sink/'>This guide</a> explains how to configure and use the RabbitMQ sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-rabbitmq-sink/'>RabbitMQ Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, RabbitMQ, Sink",
          "alias": "RabbitMQ Sink",
          "features": "Sync data of puslar topic to RabbitMQ",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-rabbitmq-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    [Doc] Add File source connector doc to Pulsar Registry repo

    Refer to:

          "name": "file-source",
          "description": "The File source connector pulls messages from files in directories and persists the messages to Pulsar topics.",
          "author": "david-streamlio",
          "contributors": "david-streamlio",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-file/'>Document</a>",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-file/'>File Source</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, File, Source",
          "alias": "File Source",
          "features": "Use File sync data",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-file-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Add jdbc sink metadata

          "name": "jdbc-sink",
          "description": "The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.",
          "author": "sijie",
          "contributors": "sijie,jiazhai,tuteng",
          "version": "2.4.1",
          "language": "en",
          "document": "<a href='http://pulsar.apache.org/docs/en/next/io-jdbc-sink/'>This guide</a> explains how to configure and use the JDBC sink connector.",
          "source": "<a href='http://pulsar.apache.org/docs/en/next/io-jdbc-sink/'>JDBC Sink</a>",
          "licensing": "Apache 2.0",
          "tags": "Pulsar IO, JDBC, Sink",
          "alias": "JDBC Sink",
          "features": "Sync data of pulsar topic to JDBC",
          "icon": "/images/connector.png",
          "download": "https://mirrors.tuna.tsinghua.edu.cn/apache/pulsar/pulsar-2.4.1/connectors/pulsar-io-jdbc-2.4.1.nar",
          "support": "Apache community",
          "supported_org": "Apache"
    

    Recommend Projects

    • React photo React

      A declarative, efficient, and flexible JavaScript library for building user interfaces.

    • Vue.js photo Vue.js

      ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

    • Typescript photo Typescript

      TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

    • TensorFlow photo TensorFlow

      An Open Source Machine Learning Framework for Everyone

    • Django photo Django

      The Web framework for perfectionists with deadlines.

    • D3 photo D3

      Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

    Recommend Topics

    • javascript

      JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

    • web

      Some thing interesting about web. New door for the world.

    • server

      A server is a program made to process requests and deliver data to clients.

    • Machine learning

      Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

    • Game

      Some thing interesting about game, make everyone happy.

    Recommend Org

    • Facebook photo Facebook

      We are working to build community through open source technology. NB: members must have two-factor auth.

    • Microsoft photo Microsoft

      Open source projects and samples from Microsoft.

    • Google photo Google

      Google โค๏ธ Open Source for everyone.

    • D3 photo D3

      Data-Driven Documents codes.