Kinesis partitioning + aggregation

[croconut]

I'm having an issue where aggregation doesn't play nicely with kinesis partitions, as all my aggregated data goes to a partition called 'a', even if all the data it's aggregating would have gone to some single other partition (e.g. if i were listening to a single database called 'user' then unaggregated records go to 'user', and aggregated records go to 'a').

Is there currently a way to get aggregation + partitioning to work together? At worst I would like to get, instead of an 'a' partition, a partition like ':a' for the aggregated records.

version: 1.43.2