Class KinesisHeaders

java.lang.Object
io.awspring.cloud.kinesis.integration.KinesisHeaders
public final class KinesisHeaders extends Object
Constants for Kinesis message headers.
Since:
4.0
Author:
Artem Bilan

  • Field Details

    • PREFIX

      public static final String PREFIX
      Kinesis headers prefix to be used by all headers added by the framework.
      See Also:

    • STREAM

      public static final String STREAM
      The "Kinesis_stream" header for sending data to Kinesis.
      See Also:

    • RECEIVED_STREAM

      public static final String RECEIVED_STREAM
      The "Kinesis_receivedStream" header for receiving data from Kinesis.
      See Also:

    • PARTITION_KEY

      public static final String PARTITION_KEY
      The "Kinesis_partitionKey" header for sending data to Kinesis.
      See Also:

    • SEQUENCE_NUMBER

      public static final String SEQUENCE_NUMBER
      The "Kinesis_sequenceNumber" header for sending data to Kinesis.
      See Also:

    • SHARD

      public static final String SHARD
      The "Kinesis_shard" header to represent Kinesis shardId.
      See Also:

    • SERVICE_RESULT

      public static final String SERVICE_RESULT
      The "Kinesis_serviceResult" header represents a KinesisResponse.
      See Also:

    • RECEIVED_PARTITION_KEY

      public static final String RECEIVED_PARTITION_KEY
      The "Kinesis_receivedPartitionKey" header for receiving data from Kinesis.
      See Also:

    • RECEIVED_SEQUENCE_NUMBER

      public static final String RECEIVED_SEQUENCE_NUMBER
      The "Kinesis_receivedSequenceNumber" header for receiving data from Kinesis.
      See Also:

    • CHECKPOINTER

      public static final String CHECKPOINTER
      The "Kinesis_checkpointer" header for checkpoint the shard sequenceNumber.
      See Also:

    • RAW_RECORD

      public static final String RAW_RECORD
      The "Kinesis_rawRecord" header represents received Kinesis record(s).
      See Also: