Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Current state: Under discussion

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA:  

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9673

...

For the Conditional  SMT the ConfigDef built will depend on the configs present, though the following would always be required:

NameTypeValidation
transformationsLISTNon null list of unique aliases.
conditionSTRINGA String matching the regular expression ([a-zA-Z0-9-]+)(:.*)?, where the first group is the condition name, as described above, and the 2nd group is optional parameters for that predicate.

The returned ConfigDef  would include the configs for the given transformations using the existing ConfigDef.embed() mechanism.

...