KStore - A Wide Column Store Backed by Apache Kafka

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>1.0.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.