-
Notifications
You must be signed in to change notification settings - Fork 18
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
Improve S3 Source Integration tests #382
Improve S3 Source Integration tests #382
Conversation
…ing time to be depndent on the test and to take into account if their are more records left to be retrieved before waiting to collect the next batch of records Signed-off-by: Aindriu Lavelle <[email protected]>
...ce-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
Outdated
Show resolved
Hide resolved
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.
LGTM! Thanks.
...ce-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationTest.java
Outdated
Show resolved
Hide resolved
...ce-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
Outdated
Show resolved
Hide resolved
...ce-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
Show resolved
Hide resolved
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 improvement.
...ce-connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationTest.java
Outdated
Show resolved
Hide resolved
…ming messages. Signed-off-by: Aindriu Lavelle <[email protected]>
a3a366b
to
8267489
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.
LGTM, thanks.
Increase performance of the S3 Integration tests by allowing the polling time to be dependent on the test and to take into account if their are more records left to be retrieved before waiting to collect the next batch of records.
This allows the consuming of messages to occur faster if additional messages are already waiting to be retrieved.
This allows different tests to allow a more subtle control of the time to wait before timing out. (previously all tests would wait the maximum 5 minutes even if only waiting for 5 messages from kafka)
This should save 2-3 minutes per Integration test run and allow on a failure run to save between 12-15 minutes on each test run.