BigPipe.Client
0.1.0
dotnet add package BigPipe.Client --version 0.1.0
NuGet\Install-Package BigPipe.Client -Version 0.1.0
<PackageReference Include="BigPipe.Client" Version="0.1.0" />
<PackageVersion Include="BigPipe.Client" Version="0.1.0" />
<PackageReference Include="BigPipe.Client" />
paket add BigPipe.Client --version 0.1.0
#r "nuget: BigPipe.Client, 0.1.0"
#:package BigPipe.Client@0.1.0
#addin nuget:?package=BigPipe.Client&version=0.1.0
#tool nuget:?package=BigPipe.Client&version=0.1.0
BigPipe for .NET
BigPipe is a high performance, Kafka-compatible realtime stream processing platform with per-topic storage: local disk, tiered, or diskless straight to object storage.
| Package | What it gives you |
|---|---|
BigPipe.Client |
Managed Kafka-protocol producer/consumer (idempotent, consumer groups), share groups, Schema Registry serializers, admin + HTTP clients, DI integration |
BigPipe.Streams |
Stream processing DSL: filter, map, group, tumbling/hopping/sliding/session windows, aggregations, stream-table joins, state stores with changelogs |
BigPipe.Analytics |
Realtime analytics: windows, streaming statistics, sketches (HyperLogLog, Count-Min, Top-K), anomaly detectors |
BigPipe.Analytics.Scripting |
Filter/query streams with C#, Python and JavaScript scripts |
BigPipe.Analytics.ML |
ML.NET: spike/change-point detection, SR-CNN, SSA forecasting, online classifiers |
BigPipe.Analytics.Torch |
TorchSharp: online autoencoder anomaly detection, TorchScript scoring |
BigPipe.Analytics.Gravicode |
GravicodeScience, HF.Net and MediaPipe.NET for stream analytics |
await using var producer = new ProducerBuilder<string, Order>().WithBootstrap("localhost:9092").Build();
await producer.SendAsync("orders", "order-1", new Order(1, 150_000m, "IDR"));
Docs: https://github.com/DotNetVibeCoderz/Vibe_Messaging/tree/main/BigPipe/docs
Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | 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. |
-
net10.0
- K4os.Compression.LZ4.Streams (>= 1.3.8)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.12)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.12)
- Microsoft.Extensions.Options (>= 10.0.12)
- Snappier (>= 1.3.1)
- ZstdSharp.Port (>= 0.8.8)
NuGet packages (2)
Showing the top 2 NuGet packages that depend on BigPipe.Client:
| Package | Downloads |
|---|---|
|
BigPipe.Analytics
BigPipe realtime analytics for .NET: stream sources and sinks, tumbling/sliding windows, streaming statistics (Welford, EWMA, quantiles), sketches (HyperLogLog, Count-Min, Top-K) and anomaly detectors (z-score, EWMA, MAD). Extend with BigPipe.Analytics.Scripting, .ML, .Torch and .Gravicode. Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
|
|
BigPipe.Streams
BigPipe.Streams: stream processing for .NET on BigPipe (and Kafka) — filter, map, group, tumbling/hopping/sliding/session windows, aggregations, stream-table joins, state stores with changelog recovery and interactive queries. Dibuat oleh Gravicode Studios dipimpin oleh Kang Fadhil. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 0.1.0 | 41 | 9/29/2026 |