This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 0bc0b9ea1 prepend package name for Record class (#295)
0bc0b9ea1 is described below
commit 0bc0b9ea1fcdaada465a39f8b23d2b5b904047bd
Author: PJ Fanning <[email protected]>
AuthorDate: Sun Dec 24 00:32:46 2023 +0100
prepend package name for Record class (#295)
* prepend package name for Record class
* Update nightly-pekko-1.1-builds.yaml
---
.github/workflows/nightly-pekko-1.1-builds.yaml | 2 +-
.../pekko/stream/connectors/kinesis/javadsl/KinesisTest.java | 9 ++++++---
2 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/nightly-pekko-1.1-builds.yaml
b/.github/workflows/nightly-pekko-1.1-builds.yaml
index 63ee71a74..d872db52c 100644
--- 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
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 class KinesisTest {
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());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
