io.simplesource.saga.shared.serdes

Class TupleSerdes

java.lang.Object

io.simplesource.saga.shared.serdes.TupleSerdes

public class TupleSerdes
extends Object

A generic utility class for creating composite serdes.

Currently supports creating a serde for Tuple2<A, B> whenever a serde for A and B is available.

Constructor Summary

Constructors

Constructor and Description
TupleSerdes()

Method Summary

Modifier and Type	Method and Description
static <A,B> org.apache.kafka.common.serialization.Serde<io.simplesource.kafka.internal.util.Tuple2<A,B>>	tuple2(org.apache.kafka.common.serialization.Serde<A> serdeA, org.apache.kafka.common.serialization.Serde<B> serdeB) A utility method for creating a serde on-the-fly for a pair Tuple2<A, B> whenever a serde is available for A and B.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TupleSerdes

public TupleSerdes()

Method Detail

tuple2

public static <A,B> org.apache.kafka.common.serialization.Serde<io.simplesource.kafka.internal.util.Tuple2<A,B>> tuple2(org.apache.kafka.common.serialization.Serde<A> serdeA,
                                                                                                                        org.apache.kafka.common.serialization.Serde<B> serdeB)

A utility method for creating a serde on-the-fly for a pair Tuple2<A, B> whenever a serde is available for A and B.

This is particularly useful for KStream joins where the join function pairs the input streams stream.

The serde is not required to perform the join, but will be required on subsequent operations on the joined stream.

Type Parameters:

A - the first type parameter

B - the second type parameter

Parameters:

serdeA - the serde for type A

serdeB - the serde for type B

Returns:

the serde for Tuple2<A, B>