Defaults

private[kafka] object Defaults

Default values used in the configuration as fallbacks when no alternative has been received

Source:
KafkaExtractorConfiguration.scala
class Object
trait Matchable
class Any

Value members

Concrete fields

val defaultAutoCommit: Boolean

Default value for auto commit behaviour

Default value for auto commit behaviour

Defaults to auto committing

Source:
KafkaExtractorConfiguration.scala
val defaultCommitInterval: FiniteDuration

Default wait in between commits

Default wait in between commits

Source:
KafkaExtractorConfiguration.scala
val defaultCommitRecovery: CommitRecovery

Default commit recovery strategy

Default commit recovery strategy

Retry recoverable commit errors before giving up the stream

Source:
KafkaExtractorConfiguration.scala
val defaultCommitTimeout: FiniteDuration

Default wait for commits to be performed

Default wait for commits to be performed

Source:
KafkaExtractorConfiguration.scala

Default amount of items that are evaluated concurrently

Default amount of items that are evaluated concurrently

Source:
KafkaExtractorConfiguration.scala

Default consumer group ID assigned to the underlying Kafka consumer

Default consumer group ID assigned to the underlying Kafka consumer

Uses the application's name and version to create a default ID

Source:
KafkaExtractorConfiguration.scala
val defaultOffsetResetStrategy: AutoOffsetReset

Default offset reset strategy

Default offset reset strategy

Reset consumer to the latest available offset if none is available

Source:
KafkaExtractorConfiguration.scala
val defaultPollInterval: FiniteDuration

Default wait in between stream-polls

Default wait in between stream-polls

Source:
KafkaExtractorConfiguration.scala
val defaultPollTimeout: FiniteDuration

Default wait for stream-polling to be performed

Default wait for stream-polling to be performed

Source:
KafkaExtractorConfiguration.scala

Default server from which to receive streaming data

Default server from which to receive streaming data

Attempt to listen on localhost

Source:
KafkaExtractorConfiguration.scala

Default port from which to fetch streaming data in the server

Default port from which to fetch streaming data in the server

Uses Kafka's default port (9092)

Source:
KafkaExtractorConfiguration.scala
val defaultSessionTimeout: FiniteDuration

Default session timeout for connecting to Kafka

Default session timeout for connecting to Kafka

Defaults to Java kafka client default

Source:
KafkaExtractorConfiguration.scala