From 017f4489c924018132fefb32ea10017e0df3d49a Mon Sep 17 00:00:00 2001
From: Bartosz Zablocki <bzablocki@google.com>
Date: Wed, 25 Sep 2024 16:58:07 +0200
Subject: [PATCH] SolaceIO: deduplicate records in the integration test
 (#32557)

---
 .../test/java/org/apache/beam/sdk/io/solace/it/SolaceIOIT.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/SolaceIOIT.java b/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/SolaceIOIT.java
index 35ee7595352d..1a2a056efd45 100644
--- a/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/SolaceIOIT.java
+++ b/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/SolaceIOIT.java
@@ -87,6 +87,7 @@ public void testRead() {
             "Read from Solace",
             SolaceIO.read()
                 .from(Queue.fromName(queueName))
+                .withDeduplicateRecords(true)
                 .withMaxNumConnections(1)
                 .withSempClientFactory(
                     BasicAuthSempClientFactory.builder()