New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: add support for kafka event startingPositionTimestamp #11479
feat: add support for kafka event startingPositionTimestamp #11479
Conversation
Codecov ReportBase: 85.79% // Head: 85.66% // Decreases project coverage by
Additional details and impacted files@@ Coverage Diff @@
## main #11479 +/- ##
==========================================
- Coverage 85.79% 85.66% -0.13%
==========================================
Files 314 314
Lines 13259 13125 -134
==========================================
- Hits 11375 11243 -132
+ Misses 1884 1882 -2
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. ☔ View full report at Codecov. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@overbit great thanks for that! I have just one comment
43e3096
to
315796e
Compare
315ca5c
to
c6b6b45
Compare
c6b6b45
to
cebb796
Compare
6529aeb
to
76dbad8
Compare
@medikoo shall we change the state from |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you @overbit! We're on a right track :)
3b99ca3
to
f7ecb9f
Compare
|
||
if ( | ||
startingPosition === 'AT_TIMESTAMP' && | ||
!(startingPositionTimestamp !== undefined && startingPositionTimestamp !== null) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's keep it simple as startingPosition === 'AT_TIMESTAMP' && startingPositionTimestamp == null
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nice
@@ -243,6 +257,10 @@ class AwsCompileKafkaEvents { | |||
}; | |||
} | |||
|
|||
if (startingPositionTimestamp !== undefined && startingPositionTimestamp !== null) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same here, let's use simpler condition
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nice
f7ecb9f
to
3b8b94a
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Test failed
3b8b94a
to
47654a3
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you @overbit !
Closes: #11478