diff --git a/events/firehose.go b/events/firehose.go index 80ce098e..aace0cff 100644 --- a/events/firehose.go +++ b/events/firehose.go @@ -39,6 +39,6 @@ type KinesisFirehoseRecordMetadata struct { ShardID string `json:"shardId"` PartitionKey string `json:"partitionKey"` SequenceNumber string `json:"sequenceNumber"` - SubsequenceNumber string `json:"subsequenceNumber"` + SubsequenceNumber int64 `json:"subsequenceNumber"` ApproximateArrivalTimestamp MilliSecondsEpochTime `json:"approximateArrivalTimestamp"` } diff --git a/events/testdata/kinesis-firehose-event.json b/events/testdata/kinesis-firehose-event.json index e57977ce..0a9c00dc 100644 --- a/events/testdata/kinesis-firehose-event.json +++ b/events/testdata/kinesis-firehose-event.json @@ -13,7 +13,7 @@ "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c317a", "approximateArrivalTimestamp": 1507217624302, "sequenceNumber": "49546986683135544286507457936321625675700192471156785154", - "subsequenceNumber": "123456" + "subsequenceNumber": 123456 } }, { @@ -25,7 +25,7 @@ "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c318a", "approximateArrivalTimestamp": 1507217624302, "sequenceNumber": "49546986683135544286507457936321625675700192471156785155", - "subsequenceNumber": "123457" + "subsequenceNumber": 123457 } } ] diff --git a/events/testdata/kinesis-firehose-response.json b/events/testdata/kinesis-firehose-response.json index b7697a5f..04cb7d4b 100644 --- a/events/testdata/kinesis-firehose-response.json +++ b/events/testdata/kinesis-firehose-response.json @@ -11,4 +11,4 @@ "result": "TRANSFORMED_STATE_DROPPED" } ] - } \ No newline at end of file + }