iemre commented on code in PR #110: URL: https://github.com/apache/flink-connector-aws/pull/110#discussion_r1367748921
########## flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisher.java: ########## @@ -289,21 +293,19 @@ private software.amazon.awssdk.services.kinesis.model.StartingPosition toSdkV2St Object marker = startingPosition.getStartingMarker(); switch (startingPosition.getShardIteratorType()) { - case AT_TIMESTAMP: - { - Preconditions.checkNotNull( - marker, "StartingPosition AT_TIMESTAMP date marker is null."); - builder.timestamp(((Date) marker).toInstant()); - break; - } + case AT_TIMESTAMP: { + Preconditions.checkNotNull( + marker, "StartingPosition AT_TIMESTAMP date marker is null."); + builder.timestamp(((Date) marker).toInstant()); + break; Review Comment: ignore accidental reformatting -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org