Kinesis Channel Adapters: resolve builders to messages #152
Description
We need to map() into build() the result of a stream for the embeddedHeadersMapper in the processMultipleRecords(). Otherwise our payload is going to have AbstractIntegrationMessageBuilder instances. The idea is to allow to process a batch of Messages. Both Kinesis channel adapter implementations.