luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update PollingConfig maxRecords method to return PollingConfig (#1275)

Browse source
This commit is contained in:
Eric Meisel 2024-03-15 16:11:22 -05:00 committed by GitHub
parent ddff314020
commit a95aa9e39e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PollingConfig.java
View file

@ -146,12 +146,13 @@ public class PollingConfig implements RetrievalSpecificConfig {
return this;
}
public void maxRecords(int maxRecords) {
public PollingConfig maxRecords(int maxRecords) {
if (maxRecords > DEFAULT_MAX_RECORDS) {
throw new IllegalArgumentException(
"maxRecords must be less than or equal to " + DEFAULT_MAX_RECORDS + " but current value is " + maxRecords());
}
this.maxRecords = maxRecords;
return this;
}
/**