Advanced State Management

This code corresponds with Chapter 6 in the upcoming O'Reilly book: Mastering Kafka Streams and ksqlDB by Mitch Seymour. The code examples here make up a small percentage of the topics we actually cover in this chapter so I highly recommend reading that chapter for a more complete understanding of advanced state management.

Running Locally

The only dependency for running these examples is Docker Compose.

Once Docker Compose is installed, you can start the local Kafka cluster using the following command:

$ docker-compose up

This tutorial includes a few different topologies. The brief description for each topology, including the command for running the topology, is shown below:

An example topology that applies custom configurations to changelog topics
```
./gradlew runTopicConfigsExample
```
An example topology that uses a fixed-size LRU cache as its state store:
```
./gradlew runLruFixedSizedStoreExample
```
An example topology that processes tombstones
```
./gradlew runTombstoneExample
```

Producing Test Data

Once your application is running, you can produce some test data using the following command:

./scripts/produce-test-data.sh