Есть ли способ настроить "waitTime" / Hold для сообщений в приложениях Spring-cloud-stream, использующих Kafka, перед отправкой в ​​последующие приложения?

Question

У меня есть 2 приложения Spring Cloud Stream «Scs-Processor» и «SCS-Sink», и я использую Kafka для отправки сообщений

Вот мой вариант использования: -

1) У меня есть сообщение1 с атрибутом полезной нагрузки " payloadIdentifier " - >> Ktopic1 --- >>, полученное SCS- Процессор

2) Теперь приходит сообщение2 - >> Это сообщение2 имеет различную полезную нагрузку, но такая же" payloadIdentifier " --- >> полученный от SCS-Processor

Теперь я хочу отправить " messageNew ", которое по сути является слиянием из message1 и message2 с тем же payloadidentifier to " SCS-Sink "

Есть ли способ проверить входящее сообщение и удерживать его в Kafka / SCS, чтобы добиться этого?

Очень ценится.