/pulsar-iotdb

This repository is used to synchronize data from IoTdb to Apache Pulsar.

Primary LanguageJavaApache License 2.0Apache-2.0

Pulsar IO :: IoTdb

This is a IoTdb Source implementation that can receive data from IoTdb tsfile, and then publish to Pulsar.

Installation

  1. Start Pulsar standalone
./bin/pulsar standalone -a 127.0.0.1 -nss
  1. Clone code and build.
git clone https://github.com/tuteng/pulsar-iotdb
cd pulsar-iotdb
mvn clean install
  1. Start connector source
./bin/pulsar-admin sources localrun -a target/pulsar-iotdb-0.0.1.nar --destination-topic-name iotdb --source-config-file src/main/resources/iotdb-source-config.yaml --name test-iotdb
  1. Consume from thie pulsar topic
./bin/pulsar-client consume -s "iotdb-name" iotdb -n 0

Configuration

Examples

Monitoring

Troubleshooting

License