Packages

p

fs2.kafka

vulcan

package vulcan

Source
package.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. vulcan
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. sealed abstract class Auth extends AnyRef

    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.
  2. final class AvroDeserializer[A] extends AnyVal
  3. final class AvroSerializer[A] extends AnyVal
  4. sealed abstract class AvroSettings[F[_]] extends AnyRef

    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.

  5. type CachedSchemaRegistryClient = io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

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

  6. type KafkaAvroDeserializer = io.confluent.kafka.serializers.KafkaAvroDeserializer

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

  7. type KafkaAvroSerializer = io.confluent.kafka.serializers.KafkaAvroSerializer

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

  8. type SchemaRegistryClient = io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

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

  9. sealed abstract class SchemaRegistryClientSettings[F[_]] extends AnyRef

    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.

Value Members

  1. def avroDeserializer[A](implicit codec: Codec[A]): AvroDeserializer[A]
  2. def avroSerializer[A](implicit codec: Codec[A]): AvroSerializer[A]
  3. object Auth
  4. object AvroDeserializer
  5. object AvroSerializer
  6. object AvroSettings
  7. object SchemaRegistryClientSettings

Inherited from AnyRef

Inherited from Any

Ungrouped