Package | Description |
---|---|
io.simplesource.saga.client.api | |
io.simplesource.saga.model.serdes | |
io.simplesource.saga.model.specs | |
io.simplesource.saga.serialization.avro |
Modifier and Type | Method and Description |
---|---|
SagaClientBuilder<A> |
SagaClientBuilder.withSerdes(SagaClientSerdes<A> serdes)
Sets the Serdes required for the saga request and saga response topics.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SagaSerdes<A>
The serdes required to serialize and deserialize the saga state and state transition topics, as well as the request and response topics.
|
Modifier and Type | Field and Description |
---|---|
SagaClientSerdes<A> |
SagaClientSpec.serdes
The serdes required for all the saga request and response topics.
|
Modifier and Type | Method and Description |
---|---|
static <A> SagaClientSerdes<A> |
AvroSerdes.sagaClientSerdes(org.apache.kafka.common.serialization.Serde<A> payloadSerde,
String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga client serdes (serdes required for the saga request and response topics)
|
static <A extends org.apache.avro.generic.GenericRecord> |
AvroSerdes.Generic.sagaClientSerdes(String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga client serdes (serdes required for the saga request and response topics)
|
static <A extends org.apache.avro.specific.SpecificRecord> |
AvroSerdes.Specific.sagaClientSerdes(String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga client serdes (serdes required for the saga request and response topics)
|
Copyright © 2019. All rights reserved.