prepend package name for Record class (#295)

* prepend package name for Record class * Update nightly-pekko-1.1-builds.yaml
apache · Dec 23, 2023 · 0bc0b9e · 0bc0b9e
1 parent 44b465e
commit 0bc0b9e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/.github/workflows/nightly-pekko-1.1-builds.yaml b/.github/workflows/nightly-pekko-1.1-builds.yaml
@@ -19,7 +19,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        JDK: [ 8, 11 ]
+        JDK: [ 8, 11, 17 ]
     env:
       JAVA_OPTS: -Xms2G -Xmx2G -Xss2M -XX:ReservedCodeCacheSize=256M -Dfile.encoding=UTF-8
 

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
@@ -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());
   }