jpzk / kafcache

Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups

Version Matrix


Codacy Badge Maven Central

In-memory Kafka Streams state store backends for low latency state store lookups. In the current version only memcached is available.


libraryDependencies += "com.madewithtea" %% "kafcache" % "1.2.0" 

Use Memcached

Memcached does not support binary keys, therefore the byte arraywill be serialized as hex string. For more information on Memcached have a look at its documentation on

  import com.madewithtea.kafcache.MemcachedStoreSupplier

  val store = Stores
      new MemcachedStoreSupplier("state-store-name", "localhost:11211"),
  .withLoggingEnabled(new java.util.HashMap[String, String]())