Ievgen Aleikin

The only thing on my eye is various Parse, ParseAs, ParseAsDelegate, ParseAsExpression - basically all those could be a single Parse overloads, but I suppose this is to keep backward...

@metoule Is it possible to: 1. Create ExpressionInterpreter with a single Parse method (+ overloads) which returns ParseResult, like in my PR. 2. Inherit Interpreter (containing all legacy methods perhaps...

Regarding user expectation, I'm definitely not aware of all use cases, but let's consider the following scenarios * Performance is not concerned Basically an expression is executed once - in...

Now I've got this constantly reproduced on Confluent 6.0 using KSQL Rest API. Getting the response { "@type": "generic_error", "error_code": 50301, "message": "Timed out while waiting for a previous command...

So basically the flow as follows: KSQL Rest API -> writes statement to kafka command topic - at this point OK KSQL -> reads statement from command topic - and...

If the property is not a Primary key or part of a composite primary key then you must add `HasAlternateKey(...)` for the target property in order to use HiLo at...

Let's say you put some identity to subject name e.g. my.event.1234, where 1234 is the key to use for 'compaction'. Then you can configure stream with MaxMsgsPerSubject=1 and DiscardPolicy=DiscardOld. With...

Without having this breaking change it's not possible to implement graceful shutdown (there are workarounds though) and catch errors properly. ```csharp Task BackgroundService.ExecuteAsync(CancellationToken stoppingToken): try { var messages = await...

@mtmk This is already in use in some cases, I'm getting ` NATS.Client.JetStream.NatsJSApiNoResponseException: No API response received from the server: Timeout` for some other operations (e.g. GetStream) - maybe you...

@mtmk Updated client to latest 2.7.12. The background service is pretty much like: ```csharp // Ephemeral WQ consumer var consumer = await js.CreateOrUpdateConsumerAsync(streamName, props.Config, ct); var messages = consumer.ConsumeAsync(cancellationToken: ct);...