priyankaku commented on code in PR #19449:
URL: https://github.com/apache/kafka/pull/19449#discussion_r2261938156
##########
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java:
##########
@@ -35,6 +36,11 @@ public final class JsonConverterConfig extends
ConverterConfig {
private static final String SCHEMAS_ENABLE_DOC = "Include schemas within
each of the serialized values and keys.";
private static final String SCHEMAS_ENABLE_DISPLAY = "Enable Schemas";
+ 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.";
Review Comment:
yes this is specific to sink connector , I will be adding this to
documentation.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
