クラス SerializationUtils
java.lang.ObjectSE
org.springframework.kafka.support.serializer.SerializationUtils
フィールド概要
フィールド修飾子と型フィールド説明static final StringSE非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。static final StringSE非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。KafkaUtils.KEY_DESERIALIZER_EXCEPTION_HEADERを優先して削除しますstatic final StringSE非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。方法の概要
修飾子と型メソッド説明static @Nullable DeserializationExceptionbyteArrayToDeserializationException(LogAccessor logger, org.apache.kafka.common.header.Header header) 直列化されたDeserializationExceptionを含むバイト配列をDeserializationExceptionに変換します。static voiddeserializationException(org.apache.kafka.common.header.Headers headers, byte[] data, ExceptionSE ex, boolean isForKeyArg) レコードヘッダーに直列化されたDeserializationExceptionを入力します。static @Nullable DeserializationExceptiongetExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, StringSE headerName, LogAccessor logger) 存在する場合は、指定されたヘッダー名からDeserializationExceptionを抽出します。static <P,T> BiFunctionSE <P, org.apache.kafka.common.header.Headers, T> propertyToMethodInvokingFunction(StringSE methodProperty, ClassSE<P> payloadType, ClassLoaderSE classLoader) プロパティ値 (FQCN.methodName) を、ペイロードとヘッダーを受け取り、何らかの値を返すBiFunctionSE に変換します。
フィールドの詳細
DESERIALIZER_EXCEPTION_HEADER_PREFIX
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。デシリアライズ例外のヘッダー名。- 導入:
- 2.8
- 関連事項:
KEY_DESERIALIZER_EXCEPTION_HEADER
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。KafkaUtils.KEY_DESERIALIZER_EXCEPTION_HEADERを優先して削除しますデシリアライズ例外のヘッダー名。- 導入:
- 2.8
- 関連事項:
VALUE_DESERIALIZER_EXCEPTION_HEADER
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。デシリアライズ例外のヘッダー名。- 導入:
- 2.8
- 関連事項:
メソッドの詳細
propertyToMethodInvokingFunction
public static <P,T> BiFunctionSE<P, org.apache.kafka.common.header.Headers, T> propertyToMethodInvokingFunction(StringSE methodProperty, ClassSE<P> payloadType, ClassLoaderSE classLoader) プロパティ値 (FQCN.methodName) を、ペイロードとヘッダーを受け取り、何らかの値を返すBiFunctionSE に変換します。メソッドにはパラメーター(P, Headers)または(P)があり、静的として宣言されている必要があります。- 型パラメーター:
P-BiFunctionSE の最初のパラメーター型。T-BiFunctionSE 戻り型。- パラメーター:
methodProperty- メソッド名プロパティ。payloadType-BiFunctionSE の最初のパラメーター型。classLoader- クラスローダー。- 戻り値:
- 関数。
deserializationException
public static void deserializationException(org.apache.kafka.common.header.Headers headers, byte[] data, ExceptionSE ex, boolean isForKeyArg) レコードヘッダーに直列化されたDeserializationExceptionを入力します。- パラメーター:
headers- ヘッダー。data- データ。ex- 例外。isForKeyArg- これがキーの逆直列化の問題である場合は true、それ以外の場合は値。- 導入:
- 2.8
getExceptionFromHeader
public static @Nullable DeserializationException getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, StringSE headerName, LogAccessor logger) 存在する場合は、指定されたヘッダー名からDeserializationExceptionを抽出します。- パラメーター:
record- コンシューマー記録。headerName- ヘッダー名。logger- エラーをログに記録するためのロガー。- 戻り値:
- 例外または null。
- 導入:
- 2.9.11
byteArrayToDeserializationException
public static @Nullable DeserializationException byteArrayToDeserializationException(LogAccessor logger, org.apache.kafka.common.header.Header header) 直列化されたDeserializationExceptionを含むバイト配列をDeserializationExceptionに変換します。- パラメーター:
logger- エラーをログに記録するためのログアクセサー。header- ヘッダー。- 戻り値:
- 逆直列化が失敗した場合は例外または null。
- 導入:
- 2.9.11
KafkaUtils.DESERIALIZER_EXCEPTION_HEADER_PREFIXを優先して削除します