{"repo":"tomasfabian/ksqlDB.RestApi.Client-DotNet","free":true,"listed":false,"github":"https://github.com/tomasfabian/ksqlDB.RestApi.Client-DotNet","clone":"git clone https://github.com/tomasfabian/ksqlDB.RestApi.Client-DotNet.git","description":"ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.","language":"C#","stars":106,"topics":["ksql","kafka","linq","dotnet","reactive-streams","csharp","ksqldb"],"license":"MIT","category":"data-pipelines","readme_excerpt":"This package enables seamless integration of KSQL push and pull queries with LINQ queries in your .NET C# applications. It allows you to perform server-side operations such as filtering, projection, limiting, and more directly on push notifications using ksqlDB push queries. This facilitates continuous processing of computations over unbounded, potentially never-ending, streams of data. In addition, the package supports executing SQL statements via the REST API. You can use it to insert records into streams, create tables and types, and perform administrative tasks such as listing available streams. ksqlDB.RestApi.Client is a contribution to Confluent ksqldb-clients Install with NuGet package manager: or with .NET CLI This adds a to your csproj file, similar to the following: An alternative option is to use Protobuf content type: Feel free to experiment with the following example in a .NET interactive Notebook: An entity class in ksqlDB.RestApi.Client represents the structure of a table or stream. An instance of the class represents a record in that stream or table while properties are mapped to columns respectively. LINQ code written in C# from the sample is equivalent to this KSQL query: In the provided C# code snippet, most of the code executes on the server side except for the IQbservable .Subscribe extension method. This method is responsible for subscribing to your ksqlDB stream, which is created using the following approach: CreateOrReplaceStreamAsync executes the foll","default_branch":null,"files":null,"tree":[],"storefront":"/r/tomasfabian","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/tomasfabian/ksqlDB.RestApi.Client-DotNet/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}