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

fs2.kafka.vulcan

package fs2.kafka.vulcan

Members list

Type members

Classlikes

sealed abstract class Auth

The available options for SchemaRegistryClientSettings#withAuth.

The available options for SchemaRegistryClientSettings#withAuth.

Available options include:

  • Auth.Basic to authenticate with username and password,

  • Auth.Bearer to authenticate with an authentication token,

  • Auth.None to not provide any authentication details.

Attributes

Companion
object
Source
Auth.scala
Supertypes
class Object
trait Matchable
class Any
object Auth

Attributes

Companion
class
Source
Auth.scala
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type
Auth.type
final class AvroDeserializer[A] extends AnyVal

Attributes

Companion
object
Source
AvroDeserializer.scala
Supertypes
class AnyVal
trait Matchable
class Any
object AvroDeserializer

Attributes

Companion
class
Source
AvroDeserializer.scala
Supertypes
class Object
trait Matchable
class Any
Self type
final class AvroSerializer[A] extends AnyVal

Attributes

Companion
object
Source
AvroSerializer.scala
Supertypes
class AnyVal
trait Matchable
class Any
object AvroSerializer

Attributes

Companion
class
Source
AvroSerializer.scala
Supertypes
class Object
trait Matchable
class Any
Self type
sealed abstract class AvroSettings[F[_]]

Describes how to create a KafkaAvroDeserializer and a KafkaAvroSerializer and which settings should be used.

Describes how to create a KafkaAvroDeserializer and a KafkaAvroSerializer and which settings should be used. Settings are tailored for the Confluent Kafka Avro serializers and deserializers.

Use AvroSettings.apply to create an instance.

Attributes

Companion
object
Source
AvroSettings.scala
Supertypes
class Object
trait Matchable
class Any
object AvroSettings

Attributes

Companion
class
Source
AvroSettings.scala
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed abstract class SchemaRegistryClientSettings[F[_]]

Describes how to create a SchemaRegistryClient and which settings should be used.

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
Supertypes
class Object
trait Matchable
class Any
object SchemaRegistryClientSettings

Attributes

Companion
class
Source
SchemaRegistryClientSettings.scala
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type

Types

type CachedSchemaRegistryClient = CachedSchemaRegistryClient

Alias for io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.

Alias for io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.

Attributes

Source
package.scala
type KafkaAvroDeserializer = KafkaAvroDeserializer

Alias for io.confluent.kafka.serializers.KafkaAvroDeserializer.

Alias for io.confluent.kafka.serializers.KafkaAvroDeserializer.

Attributes

Source
package.scala
type KafkaAvroSerializer = KafkaAvroSerializer

Alias for io.confluent.kafka.serializers.KafkaAvroSerializer.

Alias for io.confluent.kafka.serializers.KafkaAvroSerializer.

Attributes

Source
package.scala
type SchemaRegistryClient = SchemaRegistryClient

Alias for io.confluent.kafka.schemaregistry.client.SchemaRegistryClient.

Alias for io.confluent.kafka.schemaregistry.client.SchemaRegistryClient.

Attributes

Source
package.scala

Value members

Concrete methods

def avroDeserializer[A](implicit codec: Codec[A]): AvroDeserializer[A]

Attributes

Source
package.scala
def avroSerializer[A](implicit codec: Codec[A]): AvroSerializer[A]

Attributes

Source
package.scala
Generated with