Skip to content

Commit 32b457e

Browse files
authored
Merge pull request #147 from marklogic-community/feature/keyColumn-doc-tweak
Improved key column description
2 parents f5a927f + 723f799 commit 32b457e

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/com/marklogic/kafka/connect/source/MarkLogicSourceConfig.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,10 @@ private static ConfigDef getConfigDef() {
6464
"can be used to control how frequently the connector queries MarkLogic.",
6565
GROUP, -1, ConfigDef.Width.MEDIUM, "Wait Time")
6666
.define(KEY_COLUMN, Type.STRING, null, Importance.MEDIUM,
67-
"The name of a column to use for creating a key for each source record",
67+
"The name of a column to use for creating a key for each source record. Note that the accessor in your Optic " +
68+
"query may affect the column names in each row that it returns; for example, fromView will prepend " +
69+
"schema and view names to the column. Be sure your key column name matches a column in each row that " +
70+
"is returned.",
6871
GROUP, -1, ConfigDef.Width.MEDIUM, "Key Column")
6972
.define(INCLUDE_COLUMN_TYPES, Type.BOOLEAN, null, Importance.MEDIUM,
7073
"Set to true for column types to be included in the value of each source record; has no effect if the output " +

0 commit comments

Comments
 (0)