Skip to content
Kafka storage adapter for JanusGraph
Java Shell
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.
conf first commit Dec 25, 2019
.gitignore first commit Dec 25, 2019
LICENSE.txt first commit Dec 25, 2019 first commit Dec 25, 2019 first commit Dec 25, 2019
pom.xml Upgrade KCache to 3.1.1 Jan 25, 2020

Kafka Storage Adapter for JanusGraph

JanusGraph is an Apache TinkerPop enabled graph database that supports a variety of storage and indexing backends. This project adds Kafka to the supported list of backends.

Installing the adapter from a binary release

Binary releases can be found on GitHub.

This installation procedure will copy the necessary libraries, properties, and Gremlin Server configuration files into your JanusGraph installation.

  1. Download the JanusGraph release.
  2. Download the Kafka storage adapter release.
  3. Unzip the storage adapter zip file and run ./ $YOUR_JANUSGRAPH_INSTALL_DIRECTORY

Assuming you have a Kafka cluster up and running, you can connect from the Gremlin console by running:

gremlin> graph ='conf/')

To start Gremlin Server run directly or bin/ start which will also start a local Elasticsearch instance.

Installing from source

Follow these steps if you'd like to use the latest version built from source.

  1. Clone the repository. git clone
  2. Build the distribution package. mvn package -DskipTests
  3. Follow the binary installation steps starting at step 3.

Configuration Options

Property Description Default
storage.conf-file Path to the configuration file for KCache.
storage.kafka.bootstrap-servers List of Kafka brokers to connect to. Overrides the value in the KCache configuration file.
storage.kafka.topic-prefix The prefix to be used for topic names. Defaults to the graph name.
storage.kafka.rocksdb-enable Whether to enable RocksDB within KCache. true
storage.kafka.rocksdb-rootdir Root directory for RocksDB storage. /tmp
You can’t perform that action at this time.