An error occurred while fetching folder content.
user avatar
Add support for aggregated Kinesis records in SpringBootKinesisEventHandler
Halvdan Hoem Grelland authored
The current implementation of SpringBootKinesisEventHandler only handles
non-aggregated events. Attempting to process aggregated events caused
ungraceful failure.
This commit fixes that by de-aggregating any events before performing
conversion. Non-aggregated events are still handled transparently.
In addition, detection of Message<T> input is performed, and
output messages are wrapped accordingly.
2c6f71d2
Name Last commit Last update
..