diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java index 40b7c0a1462..aaf15f4eeb1 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java @@ -150,7 +150,7 @@ public class ConnectorConfig extends AbstractConfig { public static final String ERRORS_LOG_INCLUDE_MESSAGES_CONFIG = "errors.log.include.messages"; public static final String ERRORS_LOG_INCLUDE_MESSAGES_DISPLAY = "Log Error Details"; public static final boolean ERRORS_LOG_INCLUDE_MESSAGES_DEFAULT = false; - public static final String ERRORS_LOG_INCLUDE_MESSAGES_DOC = "Whether to include in the log the Connect record that resulted in a failure." + + public static final String ERRORS_LOG_INCLUDE_MESSAGES_DOC = "Whether to include in the log the Connect record that resulted in a failure. " + "For sink records, the topic, partition, offset, and timestamp will be logged. " + "For source records, the key and value (and their schemas), all headers, and the timestamp, Kafka topic, Kafka partition, source partition, " + "and source offset will be logged. " +