Defaults

private[kafka] object Defaults

Default values used as fallbacks when no alternative has been received

Source:
KafkaExtractor.scala
class Object
trait Matchable
class Any

Value members

Concrete fields

val defaultIncomingItemsTimeout: Option[FiniteDuration]

Default time to wait without receiving items before closing the Stream, for Kafka it is defined by default so that the app is not indefinitely waiting for data

Default time to wait without receiving items before closing the Stream, for Kafka it is defined by default so that the app is not indefinitely waiting for data

Source:
KafkaExtractor.scala