@@ -205,31 +205,49 @@ curl -s -X POST \
205
205
206
206
Use the command below to set up a Sink connector to a Authenticated Streaming Connection:
207
207
208
- 1. Using access_token
209
- ```shell
210
- curl -s -X POST \
211
- -H "Content-Type: application/json" \
212
- --data ' {
213
- " name" : " aep-auth-sink-connector" ,
214
- " config" : {
215
- " connector.class" : " com.adobe.platform.streaming.sink.impl.AEPSinkConnector" ,
216
- " topics" : " connect-test" ,
217
- " tasks.max" : 1,
218
- " key.converter" : " org.apache.kafka.connect.json.JsonConverter" ,
219
- " key.converter.schemas.enable" : " false" ,
220
- " value.converter" : " org.apache.kafka.connect.json.JsonConverter" ,
221
- " value.converter.schemas.enable" : " false" ,
222
- " aep.endpoint" : " https://dcs.adobedc.net/collection/{DATA_INLET_ID}" ,
223
- " aep.flush.interval.seconds" : 1,
224
- " aep.flush.bytes.kb" : 4,
225
- " aep.connection.auth.enabled" : true,
226
- " aep.connection.auth.token.type" : " access_token" ,
227
- " aep.connection.auth.client.id" : " <client_id>" ,
228
- " aep.connection.auth.client.code" : " <client_code>" ,
229
- " aep.connection.auth.client.secret" : " <client_secret>"
230
- }
231
- }' http://localhost:8083/connectors
232
- ```
208
+ 1. Using oauth2_access_token
209
+ - Create http connector
210
+ ```shell
211
+ curl -s -X POST \
212
+ -H "Content-Type: application/json" \
213
+ --data ' {
214
+ " name" : " aep-auth-sink-connector" ,
215
+ " config" : {
216
+ " connector.class" : " com.adobe.platform.streaming.sink.impl.AEPSinkConnector" ,
217
+ " topics" : " connect-test" ,
218
+ " tasks.max" : 1,
219
+ " key.converter" : " org.apache.kafka.connect.json.JsonConverter" ,
220
+ " key.converter.schemas.enable" : " false" ,
221
+ " value.converter" : " org.apache.kafka.connect.json.JsonConverter" ,
222
+ " value.converter.schemas.enable" : " false" ,
223
+ " aep.endpoint" : " https://dcs.adobedc.net/collection/{DATA_INLET_ID}" ,
224
+ " aep.flush.interval.seconds" : 1,
225
+ " aep.flush.bytes.kb" : 4,
226
+ " aep.connection.auth.enabled" : true,
227
+ " aep.connection.auth.token.type" : " oauth2_access_token" ,
228
+ " aep.connection.auth.client.id" : " <client_id>" ,
229
+ " aep.connection.auth.client.secret" : " <client_secret>"
230
+ " aep.connection.auth.endpoint" : " <ims-url>" ,
231
+ " aep.connection.endpoint.headers" : " <optional-header-that-needs-to-be-passed-to-AEP>"
232
+ }
233
+ }' http://localhost:8083/connectors
234
+ ```
235
+
236
+ Note -
237
+ 1.
238
+ `aep.connection.endpoint.headers` format should be JSON-encoded. Example: To send below 2 HTTP headers -
239
+ 1. key: `x-adobe-flow-id`, value: `341fd4f0-cdec-4912-1ab6-fb54aeb41286`
240
+ 2. key: `x-adobe-dataset-id`, value: `3096fbfd5978431948af3ba3`
241
+
242
+ Use config -
243
+ ```json
244
+ "aep.connection.endpoint.headers": "{\"x-adobe-flow-id\":\"341fd4f0-cdec-4912-1ab6-fb54aeb41286\", \"x-adobe-dataset-id\": \"3096fbfd5978431948af3ba3\"}"
245
+ ```
246
+
247
+ 2.
248
+ `aep.connection.auth.endpoint` value for prod
249
+ `<ims-url>` : `https://ims-na1.adobelogin.com`
250
+
233
251
234
252
2. Using jwt_token **[DEPRECATED]**
235
253
- Convert private.key from adobe console to PKCS8 private using command
@@ -267,19 +285,26 @@ Use the command below to set up a Sink connector to a Authenticated Streaming Co
267
285
}' http://localhost:8083/connectors
268
286
```
269
287
270
- Note - `aep.connection.endpoint.headers` format should be JSON-encoded.
271
- Example: To send below 2 HTTP headers -
272
- 1. key: `x-adobe-flow-id`, value: `341fd4f0-cdec-4912-1ab6-fb54aeb41286`
273
- 2. key: `x-adobe-dataset-id`, value: `3096fbfd5978431948af3ba3`
274
-
288
+ Note -
289
+ 1.
290
+ `aep.connection.endpoint.headers` format should be JSON-encoded. Example: To send below 2 HTTP headers -
291
+ 1. key: `x-adobe-flow-id`, value: `341fd4f0-cdec-4912-1ab6-fb54aeb41286`
292
+ 2. key: `x-adobe-dataset-id`, value: `3096fbfd5978431948af3ba3`
293
+
275
294
Use config -
276
295
```json
277
296
"aep.connection.endpoint.headers": "{\"x-adobe-flow-id\":\"341fd4f0-cdec-4912-1ab6-fb54aeb41286\", \"x-adobe-dataset-id\": \"3096fbfd5978431948af3ba3\"}"
278
297
```
279
- #### note : jwt_token authentication is deprecated
298
+
299
+ 2.
300
+ `aep.connection.auth.endpoint` value for prod
301
+ `<ims-url>` : `https://ims-na1.adobelogin.com`
302
+
303
+ #### Note : jwt_token authentication is deprecated
280
304
281
305
282
- 3. Using oauth2_access_token
306
+ 3. Using access_token
307
+
283
308
- Create http connector
284
309
```shell
285
310
curl -s -X POST \
@@ -296,27 +321,33 @@ Use the command below to set up a Sink connector to a Authenticated Streaming Co
296
321
" value.converter.schemas.enable" : " false" ,
297
322
" aep.endpoint" : " https://dcs.adobedc.net/collection/{DATA_INLET_ID}" ,
298
323
" aep.flush.interval.seconds" : 1,
299
- " aep.flush.bytes.kb" : 4,
324
+ " aep.flush.bytes.kb" : 4,
300
325
" aep.connection.auth.enabled" : true,
301
- " aep.connection.auth.token.type" : " oauth2_access_token" ,
302
- " aep.connection.auth.client.id" : " <client_id>" ,
303
- " aep.connection.auth.client.secret" : " <client_secret>"
326
+ " aep.connection.auth.token.type" : " access_token" ,
304
327
" aep.connection.auth.endpoint" : " <ims-url>" ,
305
328
" aep.connection.endpoint.headers" : " <optional-header-that-needs-to-be-passed-to-AEP>"
329
+ " aep.connection.auth.client.id" : " <client_id>" ,
330
+ " aep.connection.auth.client.code" : " <client_code>" ,
331
+ " aep.connection.auth.client.secret" : " <client_secret>"
306
332
}
307
333
}' http://localhost:8083/connectors
308
334
```
309
335
310
- Note - `aep.connection.endpoint.headers` format should be JSON-encoded.
311
- Example: To send below 2 HTTP headers -
312
- 1. key: `x-adobe-flow-id`, value: `341fd4f0-cdec-4912-1ab6-fb54aeb41286`
313
- 2. key: `x-adobe-dataset-id`, value: `3096fbfd5978431948af3ba3`
336
+ Note -
337
+ 1.
338
+ `aep.connection.endpoint.headers` format should be JSON-encoded. Example: To send below 2 HTTP headers -
339
+ 1. key: `x-adobe-flow-id`, value: `341fd4f0-cdec-4912-1ab6-fb54aeb41286`
340
+ 2. key: `x-adobe-dataset-id`, value: `3096fbfd5978431948af3ba3`
314
341
315
342
Use config -
316
343
```json
317
344
"aep.connection.endpoint.headers": "{\"x-adobe-flow-id\":\"341fd4f0-cdec-4912-1ab6-fb54aeb41286\", \"x-adobe-dataset-id\": \"3096fbfd5978431948af3ba3\"}"
318
345
```
319
346
347
+ 2.
348
+ `aep.connection.auth.endpoint` value for prod
349
+ `<ims-url>` : `https://ims-na1.adobelogin.com`
350
+
320
351
#### Batching
321
352
322
353
Use the command below to set up an Sink connector to batch up requests and reduce the number of network calls
0 commit comments