@Aaron , @marc.dipasquale , @amackenzie We can close this discussion. We figure out why the messages were redelivered by solace. The messages weren’t acknowledged by apache beam. We opened a bug issue with DirectRunner [BEAM-14313] [IT Tests] Message not acknowledged using Direct Runner - ASF JIRA
Thanks for your comments and advices.