rngcntr
rngcntr
When creating Graphs using `ConfiguredGraphFactory`, a `TemplateConfiguration` is used to generate a configuration for each graph. Once a graph is created, its configuration is manifested and can not be changed...
Fixes #3234 This PR introduces a cost based index selection algorithm which replaces the previous index selection strategies. I did intentionally not squash my commits in order to make the...
This PR was automatically created by Snyk using the credentials of a real user. ### Snyk has created this PR to fix 1 vulnerabilities in the nuget dependencies of this...
This PR was automatically created by Snyk using the credentials of a real user. ### Snyk has created this PR to fix 1 vulnerabilities in the nuget dependencies of this...
This PR was automatically created by Snyk using the credentials of a real user. ### Snyk has created this PR to fix 1 vulnerabilities in the nuget dependencies of this...
Fixes #1283 Calling both `Dispose()` and `Close()` on a consumer will yield an exception that the inner handler has already been disposed. Since there are two possible ways a KafkaMessageConsumer...
Fixes #1246
When disposing a `MotorHost`, the `KafkaMessageConsumer` is stopped and disposed. Both operations seem to be in conflict, judging from the exception message: ``` System.ObjectDisposedException: handle is destroyed at Confluent.Kafka.Impl.SafeKafkaHandle.ThrowIfHandleClosed() at...
Whenever a Kafka consumer receives Kafka message that contains a header indicating a CloudEvent (e.g. `content-type: application/cloudevents+json`), it is parsed to JSON by the `ToCloudEvent` extension from the `CloudNative.CloudEvents.Kafka` package...
This commit addresses issue #12 in terms of providing an exampe project with integration tests. Healthcheck integration has yet to be supported, as all code builds upon the capabilities Motor.NET...