Aggregation Issues

The aggregator uses the same key for all records. This creates problem in the downstream flow - e.g. we map the key to a Kafka partition, and our mapping flow breaks when we try to feed Kinesis records into Kafka. This is mentioned as a problem in comments. Any chance of getting this addressed in the near future?

Also, there doesn't seem to be mapping of key to shard. Such a mapping would be a great help...