ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.

ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.

The Aerospike sink connector pulls messages from Pulsar topics to Aerospike clusters

support sink/source for AMQP version 1.0.0

support sink/source for AMQP version 1.0.0

AoP brings the native AMQP protocol support to Pulsar by introducing an AMQP protocol handler on Pulsar brokers.

This connector allows you to make sink connections from Pulsar to AWS EventBridge.

The AWS Lambda sink connector allows you to send messages from Apache Pulsar to AWS Lambda.

Cloud Storage Connector integrates Apache Pulsar with cloud storage.

The SQS source connector is used to consume messages from Pulsar topics and publish them to AWS SQS.

The SQS source connector is used to consume messages from Amazon SQS and publish them to Pulsar.

Cloud Storage Connector integrates Apache Pulsar with cloud storage.

The Canal source connector pulls messages from MySQL to Pulsar topics.

The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters

The Debezium Microsoft SQL Server source connector pulls messages from SQL Server and persists the messages to Pulsar topics

The Debezium MongoDB source connector pulls messages from MongoDB and persists the messages to Pulsar topics

The Debezium source connector pulls messages from MySQL and persists the messages to Pulsar topics.

The Debezium source connector pulls messages from PostgreSQL and persists the messages to Pulsar topics.

The Elasticsearch sink connector pulls messages from Pulsar topics and persists the messages to indexes

The File source connector pulls messages from files in directories and persists the messages to Pulsar topics.

The Flume NG sink connector pulls messages from Pulsar topics to Flume clusters.

The Flume sink connector pulls messages from Pulsar topics to logs

The Flume source connector pulls messages from logs to Pulsar topics.

BigQuery Connector integrates Apache Pulsar with Google BigQuery.

BigQuery Connector integrates Apache Pulsar with Google BigQuery.

The Google Pub/Sub sink connector allows you to write messages from Google Pub/Sub to Apache Pulsar.

The Google Pub/Sub sink connector is used to write messages from Apache Pulsar topics to Google Cloud Pub/Sub.

Cloud Storage Connector integrates Apache Pulsar with cloud storage.

The HBase sink connector pulls the messages from Pulsar topics and persists the messages to HBase tables

The HDFS3 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files.

The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB.

The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.

The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.

kafka-connect-bigquery is a Kafka Connect connector for Google BigQuery.

kafka-connect-datagen is a Kafka Connect connector for generating mock data for testing and is not suitable for production scenarios.

The official ElasticSearch Kafka Connect Sink connector.

The official Apache Iceberg Kafka Connect Sink connector.

JR Source Connector for Apache Kafka Connect. JR (jrnd.io) is a CLI program that helps you to stream quality random data for your applications.

The official Milvus Kafka Connect Sink connector.

The official MongoDB Kafka Connect Sink connector.

The official MongoDB Kafka Connect Source connector.

The official Snowflake Kafka Connect Sink connector.

The official YugabyteDB CDC Kafka Source Connector for capturing change data from YugabyteDB.

The Kafka sink connector pulls messages from Pulsar topics and persists the messages to Kafka topics.

The Kafka source connector pulls messages from Kafka topics and persists the messages to Pulsar topics.

The Kinesis sink connector pulls data from Pulsar and persists data into Amazon Kinesis.

The Kinesis source connector pulls data from Amazon Kinesis and persists data into Pulsar

pulsar lakehouse connector

pulsar lakehouse connector

The MongoDB sink connector pulls messages from Pulsar topics and persists the messages to collections.

MoP brings the native MQTT protocol support to Pulsar by introducing a MQTT protocol handler on Pulsar brokers.

The Netty source connector opens a port that accepts incoming data via the configured network protocol and publish it to user-defined Pulsar topics

A connector to pinecone.io

The RabbitMQ sink connector pulls messages from Pulsar topics and persist the messages to RabbitMQ queues.

The RabbitMQ source connector receives messages from RabbitMQ clusters and writes messages to Pulsar topics

The Redis sink connector pulls messages from Pulsar topics and persists the messages to a Redis database.

The Snowflake sink connector is used to write messages from Apache Pulsar topics to Snowflake tables.

The Snowflake sink connector is used to write messages from Apache Pulsar topics to Snowflake tables with snowpipe streaming.

The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.

The Twitter Firehose source connector receives tweets from Twitter Firehose and writes the tweets to Pulsar topics.