kafka-connect-mqtt-1.0.0-sources.jar

<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-mqtt</artifactId>
	<version>1.0.0</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

com.datamountaineer:kafka-connect-mqtt:1.0.0

META-INF/MANIFEST.MF
mqtt-sink-ascii.txt
mqtt-source-ascii.txt
log4j.properties
com/datamountaineer/streamreactor/connect/mqtt/connection/MqttClientConnectionFn.scala
com/datamountaineer/streamreactor/connect/mqtt/config/MqttSourceSettings.scala
com/datamountaineer/streamreactor/connect/mqtt/config/MqttSinkSettings.scala
com/datamountaineer/streamreactor/connect/mqtt/config/MqttConfigConstants.scala
com/datamountaineer/streamreactor/connect/mqtt/config/MqttConfig.scala
com/datamountaineer/streamreactor/connect/mqtt/source/MqttSourceConnector.scala
com/datamountaineer/streamreactor/connect/mqtt/source/MqttManager.scala
com/datamountaineer/streamreactor/connect/mqtt/source/MqttSSLSocketFactory.scala
com/datamountaineer/streamreactor/connect/mqtt/source/MqttSourceTask.scala
com/datamountaineer/streamreactor/connect/mqtt/sink/MqttSinkTask.scala
com/datamountaineer/streamreactor/connect/mqtt/sink/MqttSinkConnector.scala
com/datamountaineer/streamreactor/connect/mqtt/sink/MqttWriter.scala