Package | Description |
---|---|
io.simplesource.saga.model.specs | |
io.simplesource.saga.serialization.avro |
Modifier and Type | Field and Description |
---|---|
SagaSerdes<A> |
SagaSpec.serdes
The serdes required for all the saga coordinator topics (request and response as well as state and state transition topics).
|
Modifier and Type | Method and Description |
---|---|
static <A> SagaSerdes<A> |
AvroSerdes.sagaSerdes(org.apache.kafka.common.serialization.Serde<A> payloadSerde,
String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
|
static <A extends org.apache.avro.generic.GenericRecord> |
AvroSerdes.Generic.sagaSerdes(String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
|
static <A extends org.apache.avro.specific.SpecificRecord> |
AvroSerdes.Specific.sagaSerdes(String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
|
Copyright © 2019. All rights reserved.