I would like the lambda code as well, I'm running into the same situation. It's hard for me to transition away from Kinesis to Kinesis Firehose as recommended, when the source data is changed to the collector token name or the source in the collector token. My users are accustomed to their logs containing the source based on the log group name. We have log groups subscribing to a single Kinesis stream today in accounts/regions. That would be preserved to a certain degree when transitioning to Firehose.
... View more