kafka-aerospike-state-store

Apache Kafka StateStore is a storage engine for managing state maintained by a stream processor.

This repo implements custom persistent StateStore backed by Aerospike Database.

Only the Processor API supports custom state stores.

Getting started

Build from source

./gradlew clean build

Install as a dependency

Read on how to install the kafka-aerospike-state-store package from GitHub Packages.

Example

Topology topology = new Topology();
topology.addSource("source", INPUT_TOPIC);
topology.addProcessor("processor", new StoreProcessorSupplier(), "source");
topology.addStateStore(new AerospikeStoreBuilder(
        new AerospikeParamsSupplier("localhost", 3000, "test", "store"),
        storeName), "processor");
topology.addSink("sink", OUTPUT_TOPIC, "processor");

License

Licensed under the Apache 2.0 License.