Allen's Apache Kafka Contributions - natengall/kafka GitHub Wiki

KAFKA-6890: Add connector level configurability for client configs

This introduces the capability for individual connectors to override consumer/producer config defaults. Connector properties that are prefixed with "producer." and "consumer." are now used to feed into the producer and consumer clients embedded within source and sink connectors respectively.


KAFKA-6895: Schema Inferencing for JsonConverter

This introduces a new configuration for the JsonConverter class called "schemas.infer.enable". When "schemas.enable" is false and the "schemas.infer.enable" flag is set to true, the converter will infer the schema from the contents of the JSON record and return that as part of the SchemaAndValue object for Sink Connectors.