Home

Welcome to the Ksql.Linq Wiki

Ksql.Linq is an open‑source, LINQ‑first data streaming library for .NET. It lets you express ksqlDB/Kafka concepts using familiar C# types and a LINQ‑style DSL, so you can model with POCOs and build streams/tables and views with strong typing end‑to‑end.

What you can do with Ksql.Linq

• Define entities with POCOs and attributes, then generate/apply KSQL DDL (CTAS and CREATE STREAM/TABLE)
• Produce/consume with simple APIs: AddAsync and ForEachAsync
• Build views with ToQuery (LINQ → KSQL), then run as CTAS
• Use Tumbling time windows with live/base/1s rows and local state (RocksDB)
• Integrate with Avro + Schema Registry, DLQ, and operational monitoring

Use the sidebar to navigate the guide, concepts, operations, and reference sections.