DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
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} |
...