Package org.apache.camel.builder.endpoint.dsl

Class Kinesis2EndpointBuilderFactory.Kinesis2HeaderNameBuilder

java.lang.Object
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2HeaderNameBuilder
Enclosing interface:
Kinesis2EndpointBuilderFactory
public static class Kinesis2EndpointBuilderFactory.Kinesis2HeaderNameBuilder extends Object
The builder of headers' name for the AWS Kinesis component.

  • Constructor Details

    • Kinesis2HeaderNameBuilder

      public Kinesis2HeaderNameBuilder()

  • Method Details

    • awsKinesisSequenceNumber

      public String awsKinesisSequenceNumber()
      The sequence number of the record, as defined in http://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html#API_PutRecord_ResponseSyntaxResponse Syntax. The option is a: String type. Group: common
      Returns:
      the name of the header AwsKinesisSequenceNumber.

    • awsKinesisApproximateArrivalTimestamp

      public String awsKinesisApproximateArrivalTimestamp()
      The time AWS assigned as the arrival time of the record. The option is a: String type. Group: common
      Returns:
      the name of the header AwsKinesisApproximateArrivalTimestamp.

    • awsKinesisPartitionKey

      public String awsKinesisPartitionKey()
      Identifies which shard in the stream the data record is assigned to. The option is a: String type. Group: common
      Returns:
      the name of the header AwsKinesisPartitionKey.

    • messageTimestamp

      public String messageTimestamp()
      The timestamp of the message. The option is a: long type. Group: common
      Returns:
      the name of the header MessageTimestamp.

    • kinesisDbResumeAction

      public String kinesisDbResumeAction()
      The resume action to execute when resuming. The option is a: String type. Group: consumer
      Returns:
      the name of the header KinesisDbResumeAction.

    • awsKinesisShardId

      public String awsKinesisShardId()
      The shard ID of the shard where the data record was placed. The option is a: String type. Group: common
      Returns:
      the name of the header AwsKinesisShardId.

    • awsKinesisFailedRecordCount

      public String awsKinesisFailedRecordCount()
      The number of records that failed in a batch put operation. The option is a: Integer type. Group: producer
      Returns:
      the name of the header AwsKinesisFailedRecordCount.

    • awsKinesisRecordCount

      public String awsKinesisRecordCount()
      The total number of records in a batch put operation. The option is a: Integer type. Group: producer
      Returns:
      the name of the header AwsKinesisRecordCount.