Last Updated: November 21, 2025
Topology & DSL
| Construct | Purpose |
|---|---|
KStream
|
Record stream processing |
KTable
|
Materialized view from changelog |
StateStore
|
Local store for joins/aggregations |
Commands
./gradlew run
Start Streams processor
kafka-topics --describe
Check partitions/state
ksql> CREATE STREAM ...
Define stream via KSQL
Monitoring
Watch for processor-lag metrics, commit interval, and rebalances in production dashboards.
💡 Pro Tip:
Use compacted topics for changelog/state stores and monitor lag per partition.