kinsumer icon indicating copy to clipboard operation
kinsumer copied to clipboard
verified publisher icon twitchscience

De-aggregation of records

Open kapadiakunal opened this issue 6 years ago • 1 comments

Hi @GarethLewin,

We've a producer which aggregates and sends records as per KPL and we're consuming records using this library. But we are getting garbage values in the records as mentioned here. Does this library take care of de-aggregation of records?

kapadiakunal avatar Sep 09 '19 07:09 kapadiakunal

Hi @kapadiakunal we do not currently de-aggregate records, but it appears as if that is relatively easy to add support for, see https://github.com/awslabs/kinesis-aggregation/blob/master/go/deaggregator/deaggregator.go#L23

I'd appreciate a PR, but if not I will attempt to get this done soon.

garethlewin avatar Nov 02 '19 16:11 garethlewin