Versions Compared

Key

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

...

For example, you could use the config:

Code Block
schemas.enable: =true
schema.content: '={"type": "struct", "fields": [{ "field": "id", "type": "string", "optional": false },{ "field": "name", "type": "string", "optional": false }]}'

and the Kafka message payload contains:

...

Users would be able use ConfigProviders to provide the contents of a file as a schema.

For Example, 

Code Block
# Config for Kafka Connect
config.providers=directory
config.providers.directory.class=org.apache.kafka.common.config.provider.DirectoryConfigProvider




# Config for Kafka Convertor
schema.content:=${directory:/schema:schema.json}

...