Skip to content

Commit d427be6

Browse files
committed
Also, fixed SQS sink Jakarta annotation issue
Signed-off-by: Krishna Kondaka <krishkdk@amazon.com>
1 parent 267ff00 commit d427be6

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

data-prepper-plugins/sqs-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/sqs/SqsThresholdConfig.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,8 @@
66
package org.opensearch.dataprepper.plugins.sink.sqs;
77

88
import com.fasterxml.jackson.annotation.JsonProperty;
9-
import jakarta.validation.constraints.Size;
9+
import jakarta.validation.constraints.Min;
10+
import jakarta.validation.constraints.Max;
1011
import org.hibernate.validator.constraints.time.DurationMax;
1112
import org.hibernate.validator.constraints.time.DurationMin;
1213
import org.opensearch.dataprepper.model.types.ByteCount;
@@ -18,8 +19,9 @@ public class SqsThresholdConfig {
1819
public static final ByteCount DEFAULT_MAX_MESSAGE_SIZE = ByteCount.parse("256kb");
1920
public static final long DEFAULT_FLUSH_INTERVAL_TIME = 30;
2021

21-
@JsonProperty("max_events_per_message")
22-
@Size(min = 1, max = 1000, message = "batch_size amount should be between 1 to 1000")
22+
@JsonProperty(value = "max_events_per_message", defaultValue="25")
23+
@Min(1)
24+
@Max(1000)
2325
private int maxEventsPerMessage = DEFAULT_MESSAGES_PER_EVENT;
2426

2527
@JsonProperty("max_message_size")

0 commit comments

Comments
 (0)