Constraints

private[kafka] object Constraints

(Programmer-biased) constraints set upon the configuration values

Source:
KafkaExtractorConfiguration.scala
class Object
trait Matchable
class Any

Value members

Concrete methods

def isValidConcurrentValue(input: Int): Boolean

Given a certain number, confirm if it is a valid number of items to be processed concurrently

Given a certain number, confirm if it is a valid number of items to be processed concurrently

Note:

We do no place any upper cap, but bear in mind that very high values won't translate to performance improvements

Source:
KafkaExtractorConfiguration.scala
def isValidDuration(duration: FiniteDuration): Boolean

Given a certain duration, confirm it complies with this configuration's constraints

Given a certain duration, confirm it complies with this configuration's constraints

Source:
KafkaExtractorConfiguration.scala
def isValidPort(input: Int): Boolean

Given a certain number, confirm if it is a valid port number

Concrete fields

val maxValidDuration: FiniteDuration

Maximum amount of time that is considered a reasonable amount

Maximum amount of time that is considered a reasonable amount

Durations supplied to configurations should be lower than this

Source:
KafkaExtractorConfiguration.scala
val minimumValidDuration: FiniteDuration

Minimum amount of time that is considered a reasonable amount

Minimum amount of time that is considered a reasonable amount

Durations supplied to configurations should be higher than this

Source:
KafkaExtractorConfiguration.scala