Skip to content

Commit 0b3eb69

Browse files
Chris Choschmalliso
authored andcommitted
DOCSP-19317: remove quotes from properties file values (#213)
1 parent f60472e commit 0b3eb69

File tree

7 files changed

+25
-25
lines changed

7 files changed

+25
-25
lines changed
Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
connector.class="com.mongodb.kafka.connect.MongoSourceConnector",
1+
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
22
connection.uri=<your mongodb uri>
33
database=<your database name>
4-
collection="customers"
4+
collection=customers
55
publish.full.document.only=true
6-
output.format.value="schema"
7-
output.schema.value="{\"type\": \"record\", \"name\": \"Customer\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\": \"visits\", \"type\": {\"type\": \"array\", \"items\": {\"type\": \"long\", \"logicalType\": \"timestamp-millis\"}}}, {\"name\": \"total_purchased\", \"type\": {\"type\": \"map\", \"values\": \"int\"}}]}"
8-
key.converter="org.apache.kafka.connect.storage.StringConverter"
9-
value.converter="io.confluent.connect.avro.AvroConverter"
6+
output.format.value=schema
7+
output.schema.value={\"type\": \"record\", \"name\": \"Customer\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\": \"visits\", \"type\": {\"type\": \"array\", \"items\": {\"type\": \"long\", \"logicalType\": \"timestamp-millis\"}}}, {\"name\": \"total_purchased\", \"type\": {\"type\": \"map\", \"values\": \"int\"}}]}
8+
key.converter=org.apache.kafka.connect.storage.StringConverter
9+
value.converter=io.confluent.connect.avro.AvroConverter
1010
value.converter.schema.registry.url=<your schema registry uri>
Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
connector.class="com.mongodb.kafka.connect.MongoSourceConnector"
2-
connection.uri="<your MongoDB connection URI>"
3-
database="customers"
4-
collection="purchases"
1+
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
2+
connection.uri=<your MongoDB connection URI>
3+
database=customers
4+
collection=purchases
55
publish.full.document.only=true
6-
output.format.value="schema"
7-
output.schema.value="{\"type\": \"record\", \"name\": \"Customer\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\": \"visits\", \"type\": {\"type\": \"array\", \"items\": {\"type\": \"long\", \"logicalType\": \"timestamp-millis\"}}}, {\"name\": \"goods_purchased\", \"type\": {\"type\": \"map\", \"values\": \"int\"}}]}"
6+
output.format.value=schema
7+
output.schema.value={\"type\": \"record\", \"name\": \"Customer\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\": \"visits\", \"type\": {\"type\": \"array\", \"items\": {\"type\": \"long\", \"logicalType\": \"timestamp-millis\"}}}, {\"name\": \"goods_purchased\", \"type\": {\"type\": \"map\", \"values\": \"int\"}}]}
88
value.converter.schemas.enable=true
9-
value.converter="org.apache.kafka.connect.json.JsonConverter"
10-
key.converter="org.apache.kafka.connect.storage.StringConverter"
9+
value.converter=org.apache.kafka.connect.json.JsonConverter
10+
key.converter=org.apache.kafka.connect.storage.StringConverter

source/includes/steps-cdc-tutorial.yaml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,11 @@ content: |
3131
.. code-block:: properties
3232
:copyable: false
3333
34-
name="mongo-source-CDCTutorial-eventroundtrip"
35-
connector.class="com.mongodb.kafka.connect.MongoSourceConnector"
36-
connection.uri="mongodb://mongo1:27017,mongo2:27017,mongo3:27017"
37-
database="CDCTutorial"
38-
collection="Source"
34+
name=mongo-source-CDCTutorial-eventroundtrip
35+
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
36+
connection.uri=mongodb://mongo1:27017,mongo2:27017,mongo3:27017
37+
database=CDCTutorial
38+
collection=Source
3939
4040
To download and start the pipeline, execute the following command from
4141
within the root directory of your cloned repository:

source/security-and-authentication/mongodb-aws-auth.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ connection URI connector property as shown in the following example:
3939

4040
.. code-block:: ini
4141

42-
connection.uri="mongodb://<AWS access key id>:<AWS secret access key>@<hostname>:<port>/?authSource=<authentication database>&authMechanism=MONGODB-AWS&authMechanismProperties=AWS_SESSION_TOKEN:<AWS session token>"
42+
connection.uri=mongodb://<AWS access key id>:<AWS secret access key>@<hostname>:<port>/?authSource=<authentication database>&authMechanism=MONGODB-AWS&authMechanismProperties=AWS_SESSION_TOKEN:<AWS session token>
4343

4444
The preceding example uses the following placeholders which you need to
4545
replace:

source/sink-connector/fundamentals/post-processors.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -762,7 +762,7 @@ setting:
762762

763763
.. code-block:: properties
764764

765-
field.renamer.mapping="[{ "oldName":"key.location", "newName":"city" }, { "oldName":"value.crepes", "newName":"flapjacks" }]"
765+
field.renamer.mapping=[{ "oldName":"key.location", "newName":"city" }, { "oldName":"value.crepes", "newName":"flapjacks" }]
766766

767767
.. _field-renamer-regex-example:
768768

source/source-connector/usage-examples/schema.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,8 @@ configure the connector to read from the ``purchases`` collection in the
6161

6262
.. code-block:: ini
6363

64-
database="customers"
65-
collection="purchases"
64+
database=customers
65+
collection=purchases
6666

6767
.. _usage-example-schema-custom-schema:
6868

source/troubleshooting/recover-from-invalid-resume-token.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ To configure your source connector to temporarily tolerate errors:
117117

118118
.. code-block:: java
119119

120-
errors.tolerance="all"
120+
errors.tolerance=all
121121

122122
#. Insert, update, or delete a document in the collection referenced by your source connector to
123123
produce a change stream event that updates your connector's resume token.
@@ -127,7 +127,7 @@ To configure your source connector to temporarily tolerate errors:
127127

128128
.. code-block:: java
129129

130-
errors.tolerance="none"
130+
errors.tolerance=none
131131

132132
For more information on the ``errors.tolerance`` option, see the
133133
:ref:`<source-configuration-error-handling>` page.

0 commit comments

Comments
 (0)