Skip to content
A Wide Column Store Backed by Apache Kafka
Java
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src
.editorconfig
.gitignore
.travis.yml
LICENSE
README.md
findbugs-exclude.xml
pom.xml

README.md

KStore - A Wide Column Store Backed by Apache Kafka

Build Status Maven Javadoc

KStore is a client library that provides a wide column store (or extensible record store) abstraction for Kafka. It implements the HBase client API and can be used as a drop-in replacement for HBase.

Maven

Releases of KStore are deployed to Maven Central.

<dependency>
    <groupId>io.kstore</groupId>
    <artifactId>kstore</artifactId>
    <version>0.1.0</version>
</dependency>

Usage

KStore can be used by configuring the value for hbase.client.connection.impl in hbase-site.xml.

<configuration>
    <property>
        <name>hbase.client.connection.impl</name>
        <value>io.kstore.KafkaStoreConnection</value>
    </property>
    <property>
        <name>kafkacache.bootstrap.servers</name>
        <value>localhost:9092</value>
    </property>
</configuration>

Internally KStore uses KCache and so all the configuration properties of KCache can be used. See the KCache documentation for further details.

See this post for more examples of how to use KStore.

You can’t perform that action at this time.