From 93384b35cf141811dcf28f535a31bc94b703bf74 Mon Sep 17 00:00:00 2001
From: PJ Fanning <pjfanning@users.noreply.github.com>
Date: Sat, 23 Dec 2023 23:58:07 +0100
Subject: [PATCH] prepend package name for Record class

---
 .../stream/connectors/kinesis/javadsl/KinesisTest.java   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/kinesis/src/test/java/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisTest.java b/kinesis/src/test/java/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisTest.java
index be505de06..6973921be 100644
--- a/kinesis/src/test/java/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisTest.java
+++ b/kinesis/src/test/java/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisTest.java
@@ -85,12 +85,15 @@ public void PullRecord() throws Exception {
                 invocation ->
                     CompletableFuture.completedFuture(
                         GetRecordsResponse.builder()
-                            .records(Record.builder().sequenceNumber("1").build())
+                            .records(software.amazon.awssdk.services.kinesis.model.Record
+                                    .builder().sequenceNumber("1").build())
                             .nextShardIterator("iter")
                             .build()));
 
-    final Source<Record, NotUsed> source = KinesisSource.basic(settings, amazonKinesisAsync);
-    final CompletionStage<Record> record = source.runWith(Sink.head(), system);
+    final Source<software.amazon.awssdk.services.kinesis.model.Record, NotUsed> source =
+            KinesisSource.basic(settings, amazonKinesisAsync);
+    final CompletionStage<software.amazon.awssdk.services.kinesis.model.Record> record =
+            source.runWith(Sink.head(), system);
 
     assertEquals("1", record.toCompletableFuture().get(10, TimeUnit.SECONDS).sequenceNumber());
   }