kafka-topology

What problem does it solve?

Kafka Streams developers often wrestle with verbose setup and boilerplate when defining topologies. This Skill provides a safe, high-level DSL to build, connect, and manage Kafka Streams topologies for the helved-utbetaling project.

Core Features & Use Cases

• Topology Builder: Define topologies with topology("name") { ... } using the DSL instead of raw Kafka Streams APIs.
• Topic, Table, and Store abstractions: Use type-safe wrappers to model streams and state for clearer, safer code.
• Error handling and testing: Built-in mechanisms with Result wrappers and StreamsMock for reliable tests.
• Best-practice enforcement: Unique processor names, explicit branching with default branches, and safe interaction with state stores.

Quick Start

Define a topology with topology("my-topology") { consume(Topics.input).produce(Topics.output) } and validate it locally using StreamsMock.