Fix test

apache · Sep 16, 2024 · 3d40f6e · 3d40f6e
1 parent 39f9052
commit 3d40f6e
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/.../test/java/org/apache/flink/connector/kinesis/source/util/KinesisStreamProxyProvider.java b/.../test/java/org/apache/flink/connector/kinesis/source/util/KinesisStreamProxyProvider.java
@@ -24,9 +24,12 @@
 
 import org.apache.commons.lang3.builder.EqualsBuilder;
 import org.apache.commons.lang3.builder.HashCodeBuilder;
+import software.amazon.awssdk.services.kinesis.model.DeregisterStreamConsumerResponse;
+import software.amazon.awssdk.services.kinesis.model.DescribeStreamConsumerResponse;
 import software.amazon.awssdk.services.kinesis.model.GetRecordsResponse;
 import software.amazon.awssdk.services.kinesis.model.HashKeyRange;
 import software.amazon.awssdk.services.kinesis.model.Record;
+import software.amazon.awssdk.services.kinesis.model.RegisterStreamConsumerResponse;
 import software.amazon.awssdk.services.kinesis.model.Shard;
 import software.amazon.awssdk.services.kinesis.model.ShardFilter;
 import software.amazon.awssdk.services.kinesis.model.ShardFilterType;
@@ -135,6 +138,23 @@ public GetRecordsResponse getRecords(
                     .build();
         }
 
+        @Override
+        public RegisterStreamConsumerResponse registerStreamConsumer(
+                String streamArn, String consumerName) {
+            return null;
+        }
+
+        @Override
+        public DeregisterStreamConsumerResponse deregisterStreamConsumer(String consumerArn) {
+            return null;
+        }
+
+        @Override
+        public DescribeStreamConsumerResponse describeStreamConsumer(
+                String streamArn, String consumerName) {
+            return null;
+        }
+
         public void setStreamSummary(Instant creationTimestamp, int retentionPeriodHours) {
             this.creationTimestamp = creationTimestamp;
             this.retentionPeriodHours = retentionPeriodHours;