IQv2 Blog Post

This is the code repository of the blog post Unlocking IQv2 in Kafka Streams: Navigating Queries and State Stores for Real-Time Insights.

Run

First make sure that everything is clean

./gradlew clean

Then, you can run the tests and see the debug logs in the stdout console. Run tests:

./gradlew test

How to navigate and understand the code

First start with the tests and understand the input and expected output of each test case. Afterward, a good starting point to navigate through the code is the enum factory StoreType. This enum implements and creates each state store's write and read logic.

Most of the state stores use the high-level DSL to materialize the stream into a table. The TimestampedKeyValueStore and the VersionedStateStore use the low-level processor API (PAPI) to write the data into the state store.