Package io.micronaut.configuration.kafka.serde

Interface SerdeRegistry

All Superinterfaces:
io.micronaut.core.order.Ordered
All Known Implementing Classes:
CompositeSerdeRegistry, JsonSerdeRegistry
public interface SerdeRegistry extends io.micronaut.core.order.Ordered
A registry of Kafka Serde instances.
Since:
1.0
Author:
Graeme Rocher

  • Method Details

    • getSerde

      <T> Serde<T> getSerde(Class<T> type)
      Obtain a Serde for the given type.
      Type Parameters:
      T - The generic type
      Parameters:
      type - The type
      Returns:
      The Serde

    • getSerializer

      default <T> Serializer<T> getSerializer(Class<T> type)
      Obtain a Serializer for the given type.
      Type Parameters:
      T - The generic type
      Parameters:
      type - The type
      Returns:
      The Serde

    • getDeserializer

      default <T> Deserializer<T> getDeserializer(Class<T> type)
      Obtain a Deserializer for the given type.
      Type Parameters:
      T - The generic type
      Parameters:
      type - The type
      Returns:
      The Serde

    • pickDeserializer

      default <T> Deserializer<T> pickDeserializer(io.micronaut.core.type.Argument<T> argument)
      Picks the most appropriate Deserializer for the given argument.
      Type Parameters:
      T - The generic type
      Parameters:
      argument - The argument
      Returns:
      The Deserializer

    • pickSerializer

      default <T> Serializer<T> pickSerializer(io.micronaut.core.type.Argument<T> argument)
      Picks the most appropriate Deserializer for the given argument.
      Type Parameters:
      T - The generic type
      Parameters:
      argument - The argument
      Returns:
      The Deserializer