diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java index 6c999e3e6a0..dac2ce56741 100644 --- a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java +++ b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java @@ -222,7 +222,7 @@ public class JsonConverter implements Converter, HeaderConverter, Versioned { private JsonConverterConfig config; private Cache fromConnectSchemaCache; private Cache toConnectSchemaCache; - private Schema schema = null; // if a schema is provided in config, this schema will be used for all messages + private Schema schema = null; // if a schema is provided in config, this schema will be used for all messages for sink connector private final JsonSerializer serializer; private final JsonDeserializer deserializer; diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java index 4d148250114..17d48c7f14c 100644 --- a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java +++ b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java @@ -38,7 +38,8 @@ public final class JsonConverterConfig extends ConverterConfig { public static final String SCHEMA_CONTENT_CONFIG = "schema.content"; public static final String SCHEMA_CONTENT_DEFAULT = null; - private static final String SCHEMA_CONTENT_DOC = "When set, this is used as the schema for all messages. Otherwise, the schema will be included in the content of each message."; + private static final String SCHEMA_CONTENT_DOC = "When set, this is used as the schema for all messages, and the schemas within each of the message will be ignored." + + "Otherwise, the schema will be included in the content of each message. This configuration applies only 'schemas.enable' is true, and it exclusively affects the sink connector."; private static final String SCHEMA_CONTENT_DISPLAY = "Schema Content"; public static final String SCHEMAS_CACHE_SIZE_CONFIG = "schemas.cache.size";