MGDCTRS-2214: Use Kamelet data types #644
Open
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
- Replaces encoder/decoder Kamelet actions with single data-type Kamelet action - Add DataType converter implementations for application/octet-stream, avro/binary, avro/x-struct, application/x-struct, application/x-java-object, application/json, plain/text mime types - Use avro/x-struct instead of avro/binary as a consumes mime type - Use single delegating schema resolver to handle both Avro and Json schema resolver based on given mime type - Introduce cos-resolve-schema-action.kamelet.yaml and cos-data-type-action.kamelet.yaml (replaces endocer/decoder action Kamelets) - Use cos-resolve-schema-action and cos-data-type-action Kamelets in KameletBindings as a generic way of converting data formats based on produces/consumes mime type information given on the connector metadata and datashape settings
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
application/octet-stream,avro/binary,avro/x-struct,application/x-struct,application/x-java-object,application/json,plain/textmime typesavro/x-structinstead ofavro/binaryas a consumes mime typecos-resolve-schema-action.kamelet.yamlandcos-data-type-action.kamelet.yaml(replaces endocer/decoder action Kamelets)cos-resolve-schema-actionandcos-data-type-actionKamelets in KameletBindings as a generic way of converting data formats based on produces/consumes mime type information given on the connector metadata and datashape settingsThe basic idea or this PR is to use generic
cos-data-type-actionKamelet in order to transform message payloads from/to different data formats. The data format information is given as consumes/produces mime type information on the connector. This mime type data shape information is translated to a data type converter implementation located in either thecos-connector-kamelets-serdesmodule or the connector implementation itself.Some data formats require schema resolving (e.g. avro and json based format). This is why the KameletBinding also uses a generic
cos-resolve-schema-actionKamelet that performs schema resolving based on additionalcontentClassand mime type information given on the connector.