Skip to content

Commit

Permalink
GH-249 Javadoc corrections.
Browse files Browse the repository at this point in the history
  • Loading branch information
siddharthjain210 committed Dec 29, 2024
1 parent 33657f7 commit 4d4fcf8
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -121,13 +121,13 @@ public void setConverter(Converter<Object, byte[]> converter) {

/**
* Configure maximum records in flight for handling backpressure. By Default, backpressure handling is not enabled.
* On number of records flights exceeding the threshold, {@link KPLBackpressureException} would be thrown.
* On number of records in flight exceeding the threshold, {@link KPLBackpressureException} would be thrown.
* If Backpressure handling is enabled, {@link KPLBackpressureException} must be handled.
* @param backPressureThreshold Defaulted to 0. Set a value greater than 0 to enable backpressure handling.
* @since 3.0.9
*/
public void setBackPressureThreshold(long backPressureThreshold) {
Assert.isTrue(backPressureThreshold > 0, "'maxInFlightRecords must be greater than 0.");
Assert.isTrue(backPressureThreshold > 0, "'backPressureThreshold must be greater than 0.");
this.backPressureThreshold = backPressureThreshold;
}

Expand Down

0 comments on commit 4d4fcf8

Please sign in to comment.