diff --git a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/util/KinesisStreamProxyProvider.java b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/util/KinesisStreamProxyProvider.java
index ab12164b..1f440706 100644
--- a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/util/KinesisStreamProxyProvider.java
+++ b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/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;