Introduction

Documentation | Confluent Hub

The plugin provides a mechanism to parse the wire format for OpenTSDB.

Installation

Confluent Hub

The following command can be used to install the plugin directly from the Confluent Hub using the Confluent Hub Client.

confluent-hub install jcustenborder/kafka-connect-transform-opentsdb:latest

Manually

The zip file that is deployed to the Confluent Hub is available under target/components/packages/. You can manually extract this zip file which includes all dependencies. All the dependencies that are required to deploy the plugin are under target/kafka-connect-target as well. Make sure that you include all the dependencies that are required to run the plugin.

1. Create a directory under the plugin.path on your Connect worker.
2. Copy all of the dependencies under the newly created subdirectory.
3. Restart the Connect worker.

Transformations

Parse OpenTSDB transformation

Key

com.github.jcustenborder.kafka.connect.opentsdb.ParseOpenTSDB$Key

Value

com.github.jcustenborder.kafka.connect.opentsdb.ParseOpenTSDB$Value

The ParseOpenTSDB transformation will parse data that is formatted with the OpenTSDB wire protocol or the telnet-style API protocol.

Tip

This transformation expects data to be a String. You are most likely going to use the StringConverter.

Configuration

Development

Building the source

mvn clean package

Contributions

Contributions are always welcomed! Before you start any development please create an issue and start a discussion. Create a pull request against your newly created issue and we're happy to see if we can merge your pull request. First and foremost any time you're adding code to the code base you need to include test coverage. Make sure that you run mvn clean package before submitting your pull to ensure that all of the tests, checkstyle rules, and the package can be successfully built.