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.
Releases of KStore are deployed to Maven Central.
<dependency>
<groupId>io.kstore</groupId>
<artifactId>kstore</artifactId>
<version>1.0.0</version>
</dependency>
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.