ksqlDB.RestApi.Client v3.2.0

• added Headers, RowOffset and RowPartition pseudocolumns to Record type
• entity creation - added WITH RETENTION_MS property

ksqlDB.RestApi.Client v3.1.0

• added ProcessingGuarantee enum value ExactlyOnceV2

ksqlDB.RestApi.Client v3.0.0

• property AsyncDisposableObject.IsDisposed was changed from public to an internal access modifier
• upgraded .NET package dependencies

Removed not supported TFMs:

• netcoreapp3.1;net5.0

Removed obsolete methods:

• KSqlFunctionsExtensions.Sign
• IAggregations<TSource>.CollectList

ksqlDB.RestApi.Client v2.6.0

• added shared values into KSqlDbStatement #39
• KSqlDbContext's CreateStream and CreateStreamQuery influence each others services collection during consecutive usages. #37

ksqlDB.RestApi.Client v2.5.0

KSqlDbRestApiClient:

PausePushQueryAsync - pauses a persistent query by query id
ResumePushQueryAsync- resume a paused persistent query. Transient queries cannot be paused or resumed.

TimeWindows:

EMIT FINAL output refinement was added for windowed aggregations

ksqlDB.RestApi.Client v2.4.0

• added System.GUID as VARCHAR ksqldb type #32
• extract field names and values (for insert and select statements) #33
• generate insert statements from entity types (covers use cases when an interface is used as the type). Added InsertProperties.UseInstanceType configuration. #33

ksqlDB.RestApi.Client v2.3.0

• added TFM for .NET 6.0

Assert topic

• asserts that a topic exists or does not exist.
• IKSqlDbRestApiClient.AssertTopicExistsAsync, IKSqlDbRestApiClient.AssertTopicNotExistsAsync, AssertTopicResponse, AssertTopicOptions

Assert schema

• Asserts that a schema exists or does not exist.
• IKSqlDbRestApiClient.AssertSchemaExistsAsync, IKSqlDbRestApiClient.AssertSchemaNotExistsAsync, AssertSchemaResponse, AssertSchemaOptions
• IKSqlDbAssertionsRestApiClient

Serialization formats

• added Protobuf_NoSR serialization format

• #27 added support to use JsonPropertyNameAttribute for anonymous objects in selects for queries

ksqlDB.RestApi.Client v2.2.0

• #27 Rename stream or table column names with the JsonPropertyNameAttribute
• #28 Source extensions were made public - bug fix
• #28 join on KSqlFunctions without aliases - bug fix

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