diff --git a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java
index 2873c058..a2fae6c7 100644
--- a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java
+++ b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java
@@ -23,7 +23,7 @@
 import java.util.function.Function;
 
 /**
- * This is a serializable function whose {@code accept()} method specifies how to convert from an
+ * This is a serializable function whose {@code apply()} method specifies how to convert from an
  * input element to the partition key, a string.
  */
 @PublicEvolving