nats-connector-spark (homepage)

A Spark Publish/Subscribe NATS Connector

@Logimethods / (0)

That library provides an Apache Spark (a fast and general engine for large-scale data processing) integration with the NATS messaging system (a highly performant cloud-native messaging system) as well as NATS Streaming (a data streaming system powered by NATS).

For a Scala version of this library, have a look at the nats-connector-spark-scala connector.


  • 1|streaming
  • 1|java
  • 1|nats

How to

Include this package in your Spark Applications using:

spark-shell, pyspark, or spark-submit

> $SPARK_HOME/bin/spark-shell --packages com.logimethods:nats-connector-spark:1.0.0


In your sbt build file, add:

libraryDependencies += "com.logimethods" % "nats-connector-spark" % "1.0.0"


In your pom.xml, add:
  <!-- list of dependencies -->


Version: 1.0.0 ( c37671 | zip | jar ) / Date: 2019-06-10 / License: MIT