ksml
ksml copied to clipboard
Axual
Kafka Streams for Low Code Environments
When a Null key or value is used in a message which is read and processed then the PythonFunction fails with a wrong parameter message. This can be reproduced by...
See #107 for issue. Added check for DataNull parameter which will be accepted Updated relevant Unit Text
This PR adds a test extension and annotations to enable KSML stream definitions without all the needed boilerplate. The extension uses the standard Kafka `TopologyTestDriver`. Some example tests are added.
Class `SchemaLoader` has a hard coded constant `DIRECTORY_SEPARATOR` set to `/`, which will probably fail if someone tries to run KSML on a Windows system. Replacing this with `File.pathSeparator()` or...
Bumps the actions-deps group with 1 update: ubi9/ubi-minimal. Updates `ubi9/ubi-minimal` from 9.5 to 9.6 [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps the prod-deps group with 2 updates in the / directory: [io.confluent:kafka-avro-serializer](https://github.com/confluentinc/schema-registry) and [io.prometheus:prometheus-metrics-instrumentation-jvm](https://github.com/prometheus/client_java). Updates `io.confluent:kafka-avro-serializer` from 7.9.0 to 7.9.1 Commits 1b2ba29 Set Confluent to 7.9.1, Kafka to 7.9.1. See...
The standard deployment for KSML is as a Kubernetes StatefulSet. This provides horizontal scaling options with predictable naming and volume claims, which is great for pipeline processing. The Kubernetes cluster...
- Test all these scenarios in the FULL Test Matrix below using AVRO & JSON Schema - Also for Protobuf when KSML fully supports Protobuf. - Consider writing some integration...
Bumps the dev-deps group with 4 updates in the / directory: [com.fasterxml.jackson.dataformat:jackson-dataformat-yaml](https://github.com/FasterXML/jackson-dataformats-text), [com.fasterxml.jackson.core:jackson-core](https://github.com/FasterXML/jackson-core), [com.fasterxml.jackson.core:jackson-databind](https://github.com/FasterXML/jackson) and [commons-io:commons-io](https://github.com/apache/commons-io). Updates `com.fasterxml.jackson.dataformat:jackson-dataformat-yaml` from 2.20.0 to 2.20.1 Commits ad7cda7 [maven-release-plugin] prepare release jackson-dataformats-text-2.20.1 d3dc677 Prep...