Pulsar I/O Custom Sink Connector

This repository contains a sample project that can be used to start off your own sink connector for Apache Pulsar

Building the connector

The first thing you need to do to start using this connector is building it. To do that, you need to install the following dependencies:

• Java 11+
• Apache Maven

After installing these dependencies, execute the following command:

mvn clean package

Trying the connector

After building the connector, you can try it by using the Docker-based installation from this repository.

1 - Start Apache Pulsar

Start the environment with the following command:

docker compose up

Wait until all containers are up so you can start the testing.

2 - Install the connector

Open a terminal to execute the following command:

util/sink-create.sh

3 - Send data to Pulsar

Open a terminal to execute the following command:

util/send-message.sh

4 - Check connector status

util/sink-status.sh

5 - Stop Apache Pulsar

Start the environment with the following command:

docker compose down

License

This project is licensed under the Apache 2.0 License.