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

Field Summary

Fields inherited from interface io.micronaut.core.order.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Method Summary

Modifier and Type	Method and Description
default <T> org.apache.kafka.common.serialization.Deserializer<T>	getDeserializer(java.lang.Class<T> type) Obtain a Deserializer for the given type.
<T> org.apache.kafka.common.serialization.Serde<T>	getSerde(java.lang.Class<T> type) Obtain a Serde for the given type.
default <T> org.apache.kafka.common.serialization.Serializer<T>	getSerializer(java.lang.Class<T> type) Obtain a Serializer for the given type.
default <T> org.apache.kafka.common.serialization.Deserializer<T>	pickDeserializer(io.micronaut.core.type.Argument<T> argument) Picks the most appropriate Deserializer for the given argument.
default <T> org.apache.kafka.common.serialization.Serializer<T>	pickSerializer(io.micronaut.core.type.Argument<T> argument) Picks the most appropriate Deserializer for the given argument.

Methods inherited from interface io.micronaut.core.order.Ordered

getOrder

Method Detail

getSerde

<T> org.apache.kafka.common.serialization.Serde<T> getSerde(java.lang.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> org.apache.kafka.common.serialization.Serializer<T> getSerializer(java.lang.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> org.apache.kafka.common.serialization.Deserializer<T> getDeserializer(java.lang.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> org.apache.kafka.common.serialization.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> org.apache.kafka.common.serialization.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