Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5138#discussion_r156231965 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper.java --- @@ -27,6 +28,7 @@ * * @param <T> The type created by the deserialization schema. */ +@PublicEvolving public class KinesisDeserializationSchemaWrapper<T> implements KinesisDeserializationSchema<T> { --- End diff -- I think this is also only meant for `@Internal` use.
---