@@ -97,87 +97,109 @@ pipelines:
97
97
# Comma separated list of record operations to generate. Allowed
98
98
# values are "create", "update", "delete", "snapshot".
99
99
# Type: string
100
+ # Required: yes
100
101
collections.*.operations: "create"
101
102
# Comma separated list of record operations to generate. Allowed
102
103
# values are "create", "update", "delete", "snapshot".
103
104
# Type: string
105
+ # Required: yes
104
106
operations: "create"
105
107
# The amount of time the generator is generating records in a burst.
106
108
# Has an effect only if ` burst.sleepTime` is set.
107
109
# Type: duration
110
+ # Required: no
108
111
burst.generateTime : " 1s"
109
112
# The time the generator "sleeps" between bursts.
110
113
# Type: duration
114
+ # Required: no
111
115
burst.sleepTime : " 0s"
112
116
# The options for the `raw` and `structured` format types. It accepts
113
117
# pairs of field names and field types, where the type can be one of:
114
118
# `int`, `string`, `time`, `bool`, `duration`.
115
119
# Type: string
120
+ # Required: no
116
121
collections.*.format.options.* : " "
117
122
# Path to the input file (only applicable if the format type is
118
123
# `file`).
119
124
# Type: string
125
+ # Required: no
120
126
collections.*.format.options.path : " "
121
127
# The format of the generated payload data (raw, structured, file).
122
128
# Type: string
129
+ # Required: no
123
130
collections.*.format.type : " "
124
131
# The options for the `raw` and `structured` format types. It accepts
125
132
# pairs of field names and field types, where the type can be one of:
126
133
# `int`, `string`, `time`, `bool`, `duration`.
127
134
# Type: string
135
+ # Required: no
128
136
format.options.* : " "
129
137
# Path to the input file (only applicable if the format type is
130
138
# `file`).
131
139
# Type: string
140
+ # Required: no
132
141
format.options.path : " "
133
142
# The format of the generated payload data (raw, structured, file).
134
143
# Type: string
144
+ # Required: no
135
145
format.type : " "
136
146
# The maximum rate in records per second, at which records are
137
147
# generated (0 means no rate limit).
138
148
# Type: float
149
+ # Required: no
139
150
rate : " 0.0"
140
151
# The time it takes to 'read' a record. Deprecated: use `rate`
141
152
# instead.
142
153
# Type: duration
154
+ # Required: no
143
155
readTime : " 0s"
144
156
# Number of records to be generated (0 means infinite).
145
157
# Type: int
158
+ # Required: no
146
159
recordCount : " 0"
147
160
# Maximum delay before an incomplete batch is read from the source.
148
161
# Type: duration
162
+ # Required: no
149
163
sdk.batch.delay : " 0"
150
164
# Maximum size of batch before it gets read from the source.
151
165
# Type: int
166
+ # Required: no
152
167
sdk.batch.size : " 0"
153
168
# Specifies whether to use a schema context name. If set to false, no
154
169
# schema context name will be used, and schemas will be saved with the
155
170
# subject name specified in the connector (not safe because of name
156
171
# conflicts).
157
172
# Type: bool
173
+ # Required: no
158
174
sdk.schema.context.enabled : " true"
159
175
# Schema context name to be used. Used as a prefix for all schema
160
176
# subject names. If empty, defaults to the connector ID.
161
177
# Type: string
178
+ # Required: no
162
179
sdk.schema.context.name : " "
163
180
# Whether to extract and encode the record key with a schema.
164
181
# Type: bool
182
+ # Required: no
165
183
sdk.schema.extract.key.enabled : " true"
166
184
# The subject of the key schema. If the record metadata contains the
167
185
# field "opencdc.collection" it is prepended to the subject name and
168
186
# separated with a dot.
169
187
# Type: string
188
+ # Required: no
170
189
sdk.schema.extract.key.subject : " key"
171
190
# Whether to extract and encode the record payload with a schema.
172
191
# Type: bool
192
+ # Required: no
173
193
sdk.schema.extract.payload.enabled : " true"
174
194
# The subject of the payload schema. If the record metadata contains
175
195
# the field "opencdc.collection" it is prepended to the subject name
176
196
# and separated with a dot.
177
197
# Type: string
198
+ # Required: no
178
199
sdk.schema.extract.payload.subject : " payload"
179
200
# The type of the payload schema.
180
201
# Type: string
202
+ # Required: no
181
203
sdk.schema.extract.type : " avro"
182
204
` ` `
183
205
<!-- /readmegen:source.parameters.yaml -->
0 commit comments