Fixes: https://github.com/spring-projects/spring-integration/issues/8592 The `XADD` command for the record can be customized with a `RedisStreamCommands.XAddOptions`. * Expose `ReactiveRedisStreamMessageHandler.setAddOptionsFunction(Function<Message<?>, RedisStreamCommands.XAddOptions> addOptionsFunction)` to allow to configure those option against the specific request message.