Skip to content

Commit

Permalink
Merge branch 'master' into linger
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten authored Jan 19, 2025
2 parents a62f643 + 645591b commit f88bccc
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,6 @@ final case class ProducerSettings(
def withClientId(clientId: String): ProducerSettings =
withProperty(ProducerConfig.CLIENT_ID_CONFIG, clientId)

def withCloseTimeout(duration: Duration): ProducerSettings =
copy(closeTimeout = duration)

def withProperty(key: String, value: AnyRef): ProducerSettings =
copy(properties = properties + (key -> value))

Expand Down Expand Up @@ -62,6 +59,9 @@ final case class ProducerSettings(
def withCompression(compression: ProducerCompression): ProducerSettings =
withProperties(compression.properties)

def withCloseTimeout(duration: Duration): ProducerSettings =
copy(closeTimeout = duration)

/**
* @param sendBufferSize
* The maximum number of record chunks that can queue up while waiting for the underlying producer to become
Expand Down

0 comments on commit f88bccc

Please sign in to comment.