exceptionfactory commented on code in PR #9741:
URL: https://github.com/apache/nifi/pull/9741#discussion_r1967822162
##########
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/ConsumeKinesisStream.java:
##########
@@ -833,8 +852,8 @@ private Date getStartStreamTimestamp(final PropertyContext
context, final DateTi
final String streamTimestamp =
context.getProperty(STREAM_POSITION_TIMESTAMP).getValue();
return new Date(
LocalDateTime.parse(streamTimestamp,
dateTimeFormatter).atZone(ZoneId.systemDefault()) // parse date/time with
system timezone
- .withZoneSameInstant(ZoneOffset.UTC) // convert to UTC
- .toInstant().toEpochMilli() // convert to epoch milliseconds
for creating Date
+ .withZoneSameInstant(ZoneOffset.UTC) // convert to UTC
+ .toInstant().toEpochMilli() // convert to epoch
milliseconds for creating Date
Review Comment:
This spacing change can be reverted.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
