jeqo commented on code in PR #12637:
URL: https://github.com/apache/kafka/pull/12637#discussion_r975521554
##########
connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java:
##########
@@ -24,20 +24,31 @@
/**
* Single message transformation for Kafka Connect record types.
- *
+ * <br/>
* Connectors can be configured with transformations to make lightweight
message-at-a-time modifications.
*/
public interface Transformation<R extends ConnectRecord<R>> extends
Configurable, Closeable {
+ String FIELD_SYNTAX_VERSION_CONFIG = "field.syntax.version";
+ String FIELD_SYNTAX_VERSION_DOC = "Defines the version of the syntax to
access fields. "
+ + "If set to `V1`, then the field paths are limited to access the
elements at the root level of the struct or map."
+ + "If set to `V2`, the syntax will support accessing nested elements.
o access nested elements, "
+ + "dotted notation is used. If dots are already included in the field
name, then backtick pairs "
+ + "can be used to wrap field names containing dots. "
+ + "e.g. to access elements from a struct/map named \"foo.bar\", "
+ + "the following format can be used to access its elements:
\"`foo.bar`.baz\".";
+
+ String FIELD_SYNTAX_VERSION_DEFAULT_VALUE = "V1";
Review Comment:
Agree, moving it to `FieldSyntaxVersion`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
