fs2-kafka-vulcan
3.5.1
API
Generated with
fs2-kafka-vulcan/fs2.kafka.vulcan/SchemaRegistryClientSettings

SchemaRegistryClientSettings

fs2.kafka.vulcan.SchemaRegistryClientSettings
See theSchemaRegistryClientSettings companion object
sealed abstract class SchemaRegistryClientSettings[F[_]]

Describes how to create a SchemaRegistryClient and which settings should be used. Settings are tailored for default implementation CachedSchemaRegistryClient.

Use SchemaRegistryClient#apply to create an instance.

Attributes

Companion
object
Source
SchemaRegistryClientSettings.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def baseUrl: String

The base URL of the schema registry service.

The base URL of the schema registry service.

Attributes

Source
SchemaRegistryClientSettings.scala
def createSchemaRegistryClient: F[SchemaRegistryClient]

Creates a new SchemaRegistryClient using the settings contained within this SchemaRegistryClientSettings.

Creates a new SchemaRegistryClient using the settings contained within this SchemaRegistryClientSettings.

Attributes

Source
SchemaRegistryClientSettings.scala
def maxCacheSize: Int

The maximum number of schemas to cache in the client.

The maximum number of schemas to cache in the client.

The default value is 1000.

Attributes

Source
SchemaRegistryClientSettings.scala
def properties: Map[String, String]

Properties provided when creating a SchemaRegistryClient.

Properties provided when creating a SchemaRegistryClient. Numerous functions in SchemaRegistryClientSettings add properties here as necessary.

Attributes

Source
SchemaRegistryClientSettings.scala
def withAuth(auth: Auth): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance with the specified authentication details.

Creates a new SchemaRegistryClientSettings instance with the specified authentication details.

Attributes

Source
SchemaRegistryClientSettings.scala
def withCreateSchemaRegistryClient(createSchemaRegistryClientWith: (String, Int, Map[String, String]) => F[SchemaRegistryClient]): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance with the specified function for creating new instances of SchemaRegistryClient from settings.

Creates a new SchemaRegistryClientSettings instance with the specified function for creating new instances of SchemaRegistryClient from settings. The arguments are baseUrl, maxCacheSize, and properties.

Attributes

Source
SchemaRegistryClientSettings.scala
def withMaxCacheSize(maxCacheSize: Int): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance with the specified maxCacheSize.

Creates a new SchemaRegistryClientSettings instance with the specified maxCacheSize.

Attributes

Source
SchemaRegistryClientSettings.scala
def withProperties(properties: (String, String)*): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

Attributes

Source
SchemaRegistryClientSettings.scala
def withProperties(properties: Map[String, String]): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

Attributes

Source
SchemaRegistryClientSettings.scala
def withProperty(key: String, value: String): SchemaRegistryClientSettings[F]

Creates a new SchemaRegistryClientSettings instance including a property with the specified key and value.

Creates a new SchemaRegistryClientSettings instance including a property with the specified key and value.

Attributes

Source
SchemaRegistryClientSettings.scala
Generated with