Errors

private[kafka] object Errors

Error messages and error-generating function to create descriptive errors whenever a configuration is not valid

Source:
KafkaExtractorConfiguration.scala
class Object
trait Matchable
class Any
Errors.type

Value members

Concrete methods

def invalidCommitInterval(interval: Option[FiniteDuration]): String
Value parameters:
interval

Invalid commit interval supplied

Returns:

An error message due to an invalid commit interval having being supplied

Source:
KafkaExtractorConfiguration.scala
def invalidCommitTimeout(timeout: Option[FiniteDuration]): String
Value parameters:
timeout

Invalid commit timeout supplied

Returns:

An error message due to an invalid commit timeout having being supplied

Source:
KafkaExtractorConfiguration.scala
def invalidPollInterval(interval: Option[FiniteDuration]): String
Value parameters:
interval

Invalid poll interval supplied

Returns:

An error message due to an invalid poll interval having being supplied

Source:
KafkaExtractorConfiguration.scala
def invalidPollTimeout(timeout: Option[FiniteDuration]): String
Value parameters:
timeout

Invalid poll timeout supplied

Returns:

An error message due to an invalid poll timeout having being supplied

Source:
KafkaExtractorConfiguration.scala
def invalidPort(port: Option[Int]): String
Value parameters:
port

Invalid port supplied

Returns:

An error message due to an invalid port having being supplied

Source:
KafkaExtractorConfiguration.scala
private def mkError[A](`type`: String, badValue: Option[A]): String

Generic function to create reasonable configuration errors

Generic function to create reasonable configuration errors

Type parameters:
A

Type of badValue

Value parameters:
`type`

Type of the error or name of the property that is not valid

badValue

Optionally, the value that caused the error in the first place

Returns:

String containing an error message informing of the error cause

Source:
KafkaExtractorConfiguration.scala