ksqlDB.RestApi.Client v2.1.0

Right Join

• select all records for the right side of the join and the matching records from the left side. If the matching records on the left side are missing, the corresponding columns will contain null values.

Aggregation functions

• MIN and MAX aggregates support for DATE, TIME, and TIMESTAMP types

CreationMetadata

Support explicit message types for Protobuf with multiple definitions:

• added KeySchemaFullName and ValueSchemaFullName

ksqlDB.RestApi.Client v2.0.0

Breaking changes:

DisposeHttpClient

KSqlDBContextOptions and KSqlDbRestApiClient - DisposeHttpClient property is by default set to false.

HttpClientFactory

constructor argument was changed from Uri to HttpClient. The IHttpClientFactory is registered with System.Net.Http.AddHttpClient for better lifecycle management

Package references

• upgraded package references Microsoft.Extensions.DependencyInjection and Microsoft.Extensions.Logging.Abstractions to v6.0.0
• added package reference Microsoft.Extensions.Http v6.0.0

Added:

• added IHttpV1ClientFactory

• KSqlDbContextOptionsBuilder.ReplaceHttpClient

• aggregate function COLLECT_LIST, COLLECT_SET, EARLIEST_BY_OFFSET, LATEST_BY_OFFSET - with Structs, Arrays, and Maps

• KSqlDbProviderOptions.DisposeHttpClient option

• KSqlDbRestApiProvider.DisposeHttpClient option

Scalar functions:

• FormatDate, FormatTime, ParseDate, ParseTime, InitCap

ksqlDB.RestApi.Client v1.6.0

• Pull query Take extension method (Limit)
• Stream and table properties KEY_SCHEMA_ID and VALUE_SCHEMA_ID
• Access record header data

Scalar functions:

• IsJsonString, JsonArrayLength, JsonConcat, JsonKeys, JsonRecords, ToJsonString

ksqlDB.RestApi.Client v1.5.0

• improved invocation function extensions

• TimeSpanToStringConverter

• added support for Time types DATE, TIME AND TIMESTAMP (ksqldb 0.20.0)

• operator (Not) Between for Time type values

ksqlDB.RestApi.Client v1.4.0

IKSqlDBContextFactory

A factory for creating derived KSqlDBContext instances.

KSqlDbServiceCollectionExtensions.AddDbContext

Registers the given ksqldb context as a service in the IServiceCollection

KSqlDbServiceCollectionExtensions.AddDbContextFactory

Registers the given ksqldb context factory as a service in the IServiceCollection

KSqlDbRestApiClient

• CreateTypeAsync - added overload without type name argument
• CreateSourceStreamAsync - creates a read-only stream
• CreateSourceTableAsync - creates a read-only table

EntityCreationMetadata

• IncludeReadOnlyProperties - Include read-only properties during entity generation.

KSqlDbContextOptionsBuilder and KSqlDbContextOptions

• SetJsonSerializerOptions - a way to configure the JsonSerializerOptions for the materialization of the incoming values.

Bug fix:

• SubscribeAsync - error propagation fix
• CreateTypeAsync - applied type name fix

ksqlDB.RestApi.Client v1.3.1

InsertProperties IncludeReadOnlyProperties

• #12 include readonly properties in Inserts config

KSqlDBContext.SaveChangesAsync

• added CancellationToken argument

ksqlDB.RestApi.Client v1.3.0

Join Within

• specify a time window for stream-stream joins

KSqlDbRestApiClient

• CreateTypeAsync added optional type name argument

Operator LIKE - String.StartsWith, String.EndsWith, String.Contains

Match a string with a specified pattern

IKSqlDBContext Add and SaveChangesAsync

Saving multiple entities with one request

Fixes:

• KSqlDbContext services collection - injected ILoggerFactory instance is registered as Singleton

ksqlDB.RestApi.Client v1.2.0

KSqlDbServiceCollectionExtensions.ConfigureKSqlDb

• registers the following dependencies: IKSqlDBContext, KSqlDbRestApiClient, IHttpClientFactory, KSqlDBContextOptions

Logging

• LogInformation about received data, executed commands and queries
• added package reference - Microsoft.Extensions.Logging.Abstractions

ksqlDB.RestApi.Client v1.1.0

• multiple joins with query comprehension syntax (GroupJoin, SelectMany, DefaultIfEmpty)

ksqlDB.RestApi.Client v1.0.0

Package was renamed to ksqlDB.RestApi.Client v1.0.0.

Breaking changes: namespaces were changed accordingly