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

Merge pull request #34 from wwwjfy/kcl-v2-format

Browse source 
fix incompatible Record struct in KCL v2
This commit is contained in:
Xavi 2018-12-11 16:22:57 -08:00 committed by GitHub
commit 6bb489ab5b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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 {