Kafka.Context.Streaming 1.2.1

.NET 8.0 This package targets .NET 8.0. The package is compatible with this framework or higher. 
dotnet add package Kafka.Context.Streaming --version 1.2.1
                    


                    

                
NuGet\Install-Package Kafka.Context.Streaming -Version 1.2.1
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="Kafka.Context.Streaming" Version="1.2.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
<PackageVersion Include="Kafka.Context.Streaming" Version="1.2.1" />
                    


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="Kafka.Context.Streaming" />
                    


                            Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package. 
paket add Kafka.Context.Streaming --version 1.2.1
                    


                    

                
#r "nuget: Kafka.Context.Streaming, 1.2.1"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
#:package Kafka.Context.Streaming@1.2.1
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package. 
#addin nuget:?package=Kafka.Context.Streaming&version=1.2.1
                    


                            Install as a Cake Addin
                        

                    

                
#tool nuget:?package=Kafka.Context.Streaming&version=1.2.1
                    


                            Install as a Cake Tool

Kafka.Context.Streaming

Engine-agnostic Streaming DSL for Kafka.Context.

Source & docs: https://github.com/synthaicode/Kafka.Context Streaming API guide: https://github.com/synthaicode/Kafka.Context/blob/main/docs/wiki/streaming-api.md

Install

dotnet add package Kafka.Context.Streaming

What this package provides

  • Query-building DSL (From/Join/Where/GroupBy/Select/Having).
  • Streaming query definitions via ToQuery(...).
  • Engine-agnostic query plans consumed by dialect packages (e.g., Flink).

Minimal usage

public sealed class AnalyticsContext : KafkaContext
{
    public AnalyticsContext(IConfiguration configuration) : base(configuration) { }

    public EventSet<Order> Orders { get; set; } = null!;
    public EventSet<OrderStats> OrderStats { get; set; } = null!;

    protected override void OnModelCreating(IModelBuilder modelBuilder)
    {
        modelBuilder.Entity<OrderStats>().ToQuery(q => q
            .From<Order>()
            .GroupBy(o => o.CustomerId)
            .Select(o => new OrderStats
            {
                CustomerId = o.CustomerId,
                Count = FlinkAgg.Count(),
                TotalAmount = FlinkAgg.Sum(o.Amount)
            }));
    }
}

Dialect packages

For actual SQL generation, install a dialect package:

  • Flink: Kafka.Context.Streaming.Flink

AI Assist

If you're unsure how to use this package, run kafka-context ai guide --copy and paste the output into your AI assistant.

Product Compatible and additional computed target framework versions.
.NET net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed.  net9.0 was computed.  net9.0-android was computed.  net9.0-browser was computed.  net9.0-ios was computed.  net9.0-maccatalyst was computed.  net9.0-macos was computed.  net9.0-tvos was computed.  net9.0-windows was computed.  net10.0 is compatible.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (2)

Showing the top 2 NuGet packages that depend on Kafka.Context.Streaming:

Package Downloads
Kafka.Context

Package Description
Kafka.Context.Streaming.Flink

Package Description

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last Updated
1.2.1 142 1/1/2026
1.2.0 210 12/22/2025