mqtt (source) conncetor for kafka
Java
Latest commit 05bf845 Nov 8, 2016 @moperacz moperacz committed on GitHub Merge pull request #25 from totojack/master
fix mqtt username property value

README.md

Mqtt to Apache Kafka Connect Build Status Download

Prerequisites

  • Apache Kafka (0.10.x version) is publish-subscribe messaging rethought as a distributed commit log.

Usage

For development:

  • run check (checkstyle, findbugs, test):
    ./gradlew clean check

  • run project:
    connect-standalone.sh /usr/local/etc/kafka/connect-standalone.properties config/mqtt.properties

    • libs needs to be added to CLASSPATH:
      • kafka-connect-mqtt-{project.version}.jar
      • org.eclipse.paho.client.mqttv3-1.0.2.jar
      • if used with ssl there are more.. (./gradlew copyRuntimeLibs copies all runtime libs to ./build/output/lib)

For production:

  • build project: ./gradlew clean jar - output ./build/libs

  • generate API documentation: ./gradlew javadoc - output ./build/docs/javadoc

License

See LICENSE file for License