confluent-kafka-python
confluent-kafka-python copied to clipboard
Refactor schema validation in JSONSerializer
Fixes #1564
JSONSerializer changes:
- Added schema.validator parameter to conf, allowing use of different JSON validators
- Default behavior [schema.validator == None] unchanged
- Added _validator attribute
- Added explicit schema validation step to init [_validator.check_schema]
- Replaced default jsonschema.validate function with _validator.validate in call
JSONDeserializer changes:
- Added conf parameter to init
- Added schema.validator parameter to conf, allowing use of different JSON validators
- Default behavior [schema.validator == None] unchanged
- Added _validator attribute
- Added explicit schema validation step to init [_validator.check_schema]
- Replaced default jsonschema.validate function with _validator.validate in call