luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix incompatible Record struct in KCL v2

Browse source
This commit is contained in:
Tony Wang 2018-10-18 16:43:58 +08:00
parent 33d58bc6e0
commit c3ff544d00
No known key found for this signature in database
GPG key ID: 624D973D837983DF
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
kcl/kcl.go
View file

@ -59,11 +59,13 @@ type ActionInitialize struct {
} }
type Record struct { type Record struct {
SequenceNumber string `json:"sequenceNumber"` SequenceNumber string `json:"sequenceNumber"`
SubSequenceNumber int `json:"subSequenceNumber"` SubSequenceNumber int `json:"subSequenceNumber"`
ApproximateArrivalTimestamp int `json:"approximateArrivalTimestamp"` PartitionKey string `json:"partitionKey"`
PartitionKey string `json:"partitionKey"` Data string `json:"data"`
Data string `json:"data"` // KCL v2 has a different format, causing failure when json.Unmarshal.
// This is not used anywhere currently, so commenting it out.
//ApproximateArrivalTimestamp int `json:"approximateArrivalTimestamp"`
} }
type ActionProcessRecords struct { type ActionProcessRecords struct {