Class BackPressureConfig

java.lang.Object
io.eventuate.messaging.kafka.basic.consumer.BackPressureConfig

public class BackPressureConfig extends Object
  • Constructor Details

    • BackPressureConfig

      public BackPressureConfig()
    • BackPressureConfig

      public BackPressureConfig(int low, int high)
  • Method Details

    • getLow

      public int getLow()
    • setLow

      public void setLow(int low)
    • getHigh

      public int getHigh()
    • setHigh

      public void setHigh(int high)