|
343 | 343 | </xsd:annotation> |
344 | 344 | <xsd:complexType> |
345 | 345 | <xsd:complexContent> |
346 | | - <xsd:extension base="outboundChannelAdapter"> |
347 | | - <xsd:attributeGroup ref="integration:channelAdapterAttributes"/> |
| 346 | + <xsd:extension base="kinesisOutboundChannelAdapter"> |
348 | 347 | <xsd:attribute name="kinesis-client" type="xsd:string" use="required"> |
349 | 348 | <xsd:annotation> |
350 | 349 | <xsd:documentation><![CDATA[ |
|
357 | 356 | </xsd:appinfo> |
358 | 357 | </xsd:annotation> |
359 | 358 | </xsd:attribute> |
360 | | - <xsd:attribute name="stream" type="xsd:string"> |
361 | | - <xsd:annotation> |
362 | | - <xsd:documentation><![CDATA[ |
363 | | - The name of the stream to put the data record into. |
364 | | - Mutually exclusive with 'stream-expression'. |
365 | | - ]]></xsd:documentation> |
366 | | - </xsd:annotation> |
367 | | - </xsd:attribute> |
368 | | - <xsd:attribute name="stream-expression" type="xsd:string"> |
369 | | - <xsd:annotation> |
370 | | - <xsd:documentation><![CDATA[ |
371 | | - The name of the stream to put the data record into. |
372 | | - Mutually exclusive with 'stream'. |
373 | | - ]]></xsd:documentation> |
374 | | - </xsd:annotation> |
375 | | - </xsd:attribute> |
376 | | - <xsd:attribute name="partition-key" type="xsd:string"> |
377 | | - <xsd:annotation> |
378 | | - <xsd:documentation><![CDATA[ |
379 | | - Determines which shard in the stream the data record is assigned to. |
380 | | - Mutually exclusive with 'partition-key-expression'. |
381 | | - ]]></xsd:documentation> |
382 | | - </xsd:annotation> |
383 | | - </xsd:attribute> |
384 | | - <xsd:attribute name="partition-key-expression" type="xsd:string"> |
385 | | - <xsd:annotation> |
386 | | - <xsd:documentation><![CDATA[ |
387 | | - Determines which shard in the stream the data record is assigned to. |
388 | | - Mutually exclusive with 'partition-key'. |
389 | | - ]]></xsd:documentation> |
390 | | - </xsd:annotation> |
391 | | - </xsd:attribute> |
392 | | - <xsd:attribute name="explicit-hash-key" type="xsd:string"> |
393 | | - <xsd:annotation> |
394 | | - <xsd:documentation><![CDATA[ |
395 | | - The hash value used to explicitly determine the shard |
396 | | - the data record is assigned to by overriding the partition key hash. |
397 | | - Mutually exclusive with 'explicit-hash-key-expression'. |
398 | | - ]]></xsd:documentation> |
399 | | - </xsd:annotation> |
400 | | - </xsd:attribute> |
401 | | - <xsd:attribute name="explicit-hash-key-expression" type="xsd:string"> |
402 | | - <xsd:annotation> |
403 | | - <xsd:documentation><![CDATA[ |
404 | | - The hash value used to explicitly determine the shard |
405 | | - the data record is assigned to by overriding the partition key hash. |
406 | | - Mutually exclusive with 'explicit-hash-key'. |
407 | | - ]]></xsd:documentation> |
408 | | - </xsd:annotation> |
409 | | - </xsd:attribute> |
410 | | - <xsd:attribute name="sequence-number-expression" type="xsd:string"> |
411 | | - <xsd:annotation> |
412 | | - <xsd:documentation><![CDATA[ |
413 | | - Guarantees strictly increasing sequence numbers, |
414 | | - for puts from the same client and to the same partition key. |
415 | | - If this parameter is not set, records |
416 | | - are coarsely ordered based on arrival time. |
417 | | - ]]></xsd:documentation> |
418 | | - </xsd:annotation> |
419 | | - </xsd:attribute> |
420 | | - <xsd:attribute name="embedded-headers-mapper" type="xsd:string"> |
421 | | - <xsd:annotation> |
422 | | - <xsd:documentation><![CDATA[ |
423 | | - 'org.springframework.integration.mapping.OutboundMessageMapper<byte[]>' bean reference |
424 | | - for embedding message headers into the record data together with payload. |
425 | | - ]]></xsd:documentation> |
426 | | - <xsd:appinfo> |
427 | | - <tool:annotation kind="ref"> |
428 | | - <tool:expected-type type="org.springframework.integration.mapping.OutboundMessageMapper"/> |
429 | | - </tool:annotation> |
430 | | - </xsd:appinfo> |
431 | | - </xsd:annotation> |
432 | | - </xsd:attribute> |
433 | | - <xsd:attribute name="message-converter" type="xsd:string"> |
434 | | - <xsd:annotation> |
435 | | - <xsd:documentation><![CDATA[ |
436 | | - 'org.springframework.messaging.converter.MessageConverter' bean reference |
437 | | - for converting payload to 'byte[]' for Kinesis record. |
438 | | - ]]></xsd:documentation> |
439 | | - <xsd:appinfo> |
440 | | - <tool:annotation kind="ref"> |
441 | | - <tool:expected-type type="org.springframework.messaging.converter.MessageConverter"/> |
442 | | - </tool:annotation> |
443 | | - </xsd:appinfo> |
444 | | - </xsd:annotation> |
445 | | - </xsd:attribute> |
446 | 359 | </xsd:extension> |
447 | 360 | </xsd:complexContent> |
448 | 361 | </xsd:complexType> |
|
458 | 371 | </xsd:annotation> |
459 | 372 | <xsd:complexType> |
460 | 373 | <xsd:complexContent> |
461 | | - <xsd:extension base="outboundChannelAdapter"> |
462 | | - <xsd:attributeGroup ref="integration:channelAdapterAttributes"/> |
| 374 | + <xsd:extension base="kinesisOutboundChannelAdapter"> |
463 | 375 | <xsd:attribute name="kinesis-producer" type="xsd:string" use="required"> |
464 | 376 | <xsd:annotation> |
465 | 377 | <xsd:documentation><![CDATA[ |
|
472 | 384 | </xsd:appinfo> |
473 | 385 | </xsd:annotation> |
474 | 386 | </xsd:attribute> |
475 | | - <xsd:attribute name="stream" type="xsd:string"> |
476 | | - <xsd:annotation> |
477 | | - <xsd:documentation><![CDATA[ |
478 | | - The name of the stream to put the data record into. |
479 | | - Mutually exclusive with 'stream-expression'. |
480 | | - ]]></xsd:documentation> |
481 | | - </xsd:annotation> |
482 | | - </xsd:attribute> |
483 | | - <xsd:attribute name="stream-expression" type="xsd:string"> |
484 | | - <xsd:annotation> |
485 | | - <xsd:documentation><![CDATA[ |
486 | | - The name of the stream to put the data record into. |
487 | | - Mutually exclusive with 'stream'. |
488 | | - ]]></xsd:documentation> |
489 | | - </xsd:annotation> |
490 | | - </xsd:attribute> |
491 | | - <xsd:attribute name="partition-key" type="xsd:string"> |
492 | | - <xsd:annotation> |
493 | | - <xsd:documentation><![CDATA[ |
494 | | - Determines which shard in the stream the data record is assigned to. |
495 | | - Mutually exclusive with 'partition-key-expression'. |
496 | | - ]]></xsd:documentation> |
497 | | - </xsd:annotation> |
498 | | - </xsd:attribute> |
499 | | - <xsd:attribute name="partition-key-expression" type="xsd:string"> |
500 | | - <xsd:annotation> |
501 | | - <xsd:documentation><![CDATA[ |
502 | | - Determines which shard in the stream the data record is assigned to. |
503 | | - Mutually exclusive with 'partition-key'. |
504 | | - ]]></xsd:documentation> |
505 | | - </xsd:annotation> |
506 | | - </xsd:attribute> |
507 | | - <xsd:attribute name="explicit-hash-key" type="xsd:string"> |
508 | | - <xsd:annotation> |
509 | | - <xsd:documentation><![CDATA[ |
510 | | - The hash value used to explicitly determine the shard |
511 | | - the data record is assigned to by overriding the partition key hash. |
512 | | - Mutually exclusive with 'explicit-hash-key-expression'. |
513 | | - ]]></xsd:documentation> |
514 | | - </xsd:annotation> |
515 | | - </xsd:attribute> |
516 | | - <xsd:attribute name="explicit-hash-key-expression" type="xsd:string"> |
517 | | - <xsd:annotation> |
518 | | - <xsd:documentation><![CDATA[ |
519 | | - The hash value used to explicitly determine the shard |
520 | | - the data record is assigned to by overriding the partition key hash. |
521 | | - Mutually exclusive with 'explicit-hash-key'. |
522 | | - ]]></xsd:documentation> |
523 | | - </xsd:annotation> |
524 | | - </xsd:attribute> |
525 | | - <xsd:attribute name="sequence-number-expression" type="xsd:string"> |
526 | | - <xsd:annotation> |
527 | | - <xsd:documentation><![CDATA[ |
528 | | - Guarantees strictly increasing sequence numbers, |
529 | | - for puts from the same client and to the same partition key. |
530 | | - If this parameter is not set, records |
531 | | - are coarsely ordered based on arrival time. |
532 | | - ]]></xsd:documentation> |
533 | | - </xsd:annotation> |
534 | | - </xsd:attribute> |
535 | | - <xsd:attribute name="embedded-headers-mapper" type="xsd:string"> |
536 | | - <xsd:annotation> |
537 | | - <xsd:documentation><![CDATA[ |
538 | | - 'org.springframework.integration.mapping.OutboundMessageMapper<byte[]>' bean reference |
539 | | - for embedding message headers into the record data together with payload. |
540 | | - ]]></xsd:documentation> |
541 | | - <xsd:appinfo> |
542 | | - <tool:annotation kind="ref"> |
543 | | - <tool:expected-type type="org.springframework.integration.mapping.OutboundMessageMapper"/> |
544 | | - </tool:annotation> |
545 | | - </xsd:appinfo> |
546 | | - </xsd:annotation> |
547 | | - </xsd:attribute> |
548 | | - <xsd:attribute name="message-converter" type="xsd:string"> |
549 | | - <xsd:annotation> |
550 | | - <xsd:documentation><![CDATA[ |
551 | | - 'org.springframework.messaging.converter.MessageConverter' bean reference |
552 | | - for converting payload to 'byte[]' for Kinesis record. |
553 | | - ]]></xsd:documentation> |
554 | | - <xsd:appinfo> |
555 | | - <tool:annotation kind="ref"> |
556 | | - <tool:expected-type type="org.springframework.messaging.converter.MessageConverter"/> |
557 | | - </tool:annotation> |
558 | | - </xsd:appinfo> |
559 | | - </xsd:annotation> |
560 | | - </xsd:attribute> |
561 | 387 | <xsd:attribute name="flush-duration" type="xsd:long"> |
562 | 388 | <xsd:annotation> |
563 | 389 | <xsd:documentation><![CDATA[ |
|
1561 | 1387 | </xsd:attribute> |
1562 | 1388 | </xsd:attributeGroup> |
1563 | 1389 |
|
| 1390 | + <xsd:complexType name="kinesisOutboundChannelAdapter"> |
| 1391 | + <xsd:complexContent> |
| 1392 | + <xsd:extension base="outboundChannelAdapter"> |
| 1393 | + <xsd:attributeGroup ref="integration:channelAdapterAttributes"/> |
| 1394 | + <xsd:attribute name="stream" type="xsd:string"> |
| 1395 | + <xsd:annotation> |
| 1396 | + <xsd:documentation><![CDATA[ |
| 1397 | + The name of the stream to put the data record into. |
| 1398 | + Mutually exclusive with 'stream-expression'. |
| 1399 | + ]]></xsd:documentation> |
| 1400 | + </xsd:annotation> |
| 1401 | + </xsd:attribute> |
| 1402 | + <xsd:attribute name="stream-expression" type="xsd:string"> |
| 1403 | + <xsd:annotation> |
| 1404 | + <xsd:documentation><![CDATA[ |
| 1405 | + The name of the stream to put the data record into. |
| 1406 | + Mutually exclusive with 'stream'. |
| 1407 | + ]]></xsd:documentation> |
| 1408 | + </xsd:annotation> |
| 1409 | + </xsd:attribute> |
| 1410 | + <xsd:attribute name="partition-key" type="xsd:string"> |
| 1411 | + <xsd:annotation> |
| 1412 | + <xsd:documentation><![CDATA[ |
| 1413 | + Determines which shard in the stream the data record is assigned to. |
| 1414 | + Mutually exclusive with 'partition-key-expression'. |
| 1415 | + ]]></xsd:documentation> |
| 1416 | + </xsd:annotation> |
| 1417 | + </xsd:attribute> |
| 1418 | + <xsd:attribute name="partition-key-expression" type="xsd:string"> |
| 1419 | + <xsd:annotation> |
| 1420 | + <xsd:documentation><![CDATA[ |
| 1421 | + Determines which shard in the stream the data record is assigned to. |
| 1422 | + Mutually exclusive with 'partition-key'. |
| 1423 | + ]]></xsd:documentation> |
| 1424 | + </xsd:annotation> |
| 1425 | + </xsd:attribute> |
| 1426 | + <xsd:attribute name="explicit-hash-key" type="xsd:string"> |
| 1427 | + <xsd:annotation> |
| 1428 | + <xsd:documentation><![CDATA[ |
| 1429 | + The hash value used to explicitly determine the shard |
| 1430 | + the data record is assigned to by overriding the partition key hash. |
| 1431 | + Mutually exclusive with 'explicit-hash-key-expression'. |
| 1432 | + ]]></xsd:documentation> |
| 1433 | + </xsd:annotation> |
| 1434 | + </xsd:attribute> |
| 1435 | + <xsd:attribute name="explicit-hash-key-expression" type="xsd:string"> |
| 1436 | + <xsd:annotation> |
| 1437 | + <xsd:documentation><![CDATA[ |
| 1438 | + The hash value used to explicitly determine the shard |
| 1439 | + the data record is assigned to by overriding the partition key hash. |
| 1440 | + Mutually exclusive with 'explicit-hash-key'. |
| 1441 | + ]]></xsd:documentation> |
| 1442 | + </xsd:annotation> |
| 1443 | + </xsd:attribute> |
| 1444 | + <xsd:attribute name="sequence-number-expression" type="xsd:string"> |
| 1445 | + <xsd:annotation> |
| 1446 | + <xsd:documentation><![CDATA[ |
| 1447 | + Guarantees strictly increasing sequence numbers, |
| 1448 | + for puts from the same client and to the same partition key. |
| 1449 | + If this parameter is not set, records |
| 1450 | + are coarsely ordered based on arrival time. |
| 1451 | + ]]></xsd:documentation> |
| 1452 | + </xsd:annotation> |
| 1453 | + </xsd:attribute> |
| 1454 | + <xsd:attribute name="embedded-headers-mapper" type="xsd:string"> |
| 1455 | + <xsd:annotation> |
| 1456 | + <xsd:documentation><![CDATA[ |
| 1457 | + 'org.springframework.integration.mapping.OutboundMessageMapper<byte[]>' bean reference |
| 1458 | + for embedding message headers into the record data together with payload. |
| 1459 | + ]]></xsd:documentation> |
| 1460 | + <xsd:appinfo> |
| 1461 | + <tool:annotation kind="ref"> |
| 1462 | + <tool:expected-type type="org.springframework.integration.mapping.OutboundMessageMapper"/> |
| 1463 | + </tool:annotation> |
| 1464 | + </xsd:appinfo> |
| 1465 | + </xsd:annotation> |
| 1466 | + </xsd:attribute> |
| 1467 | + <xsd:attribute name="message-converter" type="xsd:string"> |
| 1468 | + <xsd:annotation> |
| 1469 | + <xsd:documentation><![CDATA[ |
| 1470 | + 'org.springframework.messaging.converter.MessageConverter' bean reference |
| 1471 | + for converting payload to 'byte[]' for Kinesis record. |
| 1472 | + ]]></xsd:documentation> |
| 1473 | + <xsd:appinfo> |
| 1474 | + <tool:annotation kind="ref"> |
| 1475 | + <tool:expected-type type="org.springframework.messaging.converter.MessageConverter"/> |
| 1476 | + </tool:annotation> |
| 1477 | + </xsd:appinfo> |
| 1478 | + </xsd:annotation> |
| 1479 | + </xsd:attribute> |
| 1480 | + </xsd:extension> |
| 1481 | + </xsd:complexContent> |
| 1482 | + </xsd:complexType> |
| 1483 | + |
1564 | 1484 | <xsd:simpleType name="kinesisCheckpointMode"> |
1565 | 1485 | <xsd:restriction base="xsd:token"> |
1566 | 1486 | <xsd:enumeration value="record"/> |
|
0 commit comments