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.
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.
./install.sh $YOUR_JANUSGRAPH_INSTALL_DIRECTORY
Assuming you have a Kafka cluster up and running, you can connect from the Gremlin console by running:
gremlin> graph = JanusGraphFactory.open('conf/janusgraph-kafka.properties')
To start Gremlin Server run gremlin-server.sh
directly or bin/janusgraph.sh start
which will also start a local Elasticsearch instance.
Follow these steps if you'd like to use the latest version built from source.
git clone http://github.com/rayokota/janusgraph-kafka
mvn package -DskipTests
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.kafkacache.backing.cache |
The backing cache for KCache, one of memory , bdbje , lmdb , mapdb , or rocksdb . |
memory |
storage.kafka.kafkacache.data.dir |
Root directory for backing cache storage. | /tmp |