public interface OutputDescriptorProvider
SystemDescriptors
that return OutputDescriptors
parameterized by the type of
the provided stream level serde.Modifier and Type | Method and Description |
---|---|
<StreamMessageType> |
getOutputDescriptor(java.lang.String streamId,
Serde<StreamMessageType> serde)
Gets an
OutputDescriptor representing an output stream on this system that uses the provided
stream specific serde instead of the default system serde. |
<StreamMessageType> OutputDescriptor<StreamMessageType,? extends OutputDescriptor> getOutputDescriptor(java.lang.String streamId, Serde<StreamMessageType> serde)
OutputDescriptor
representing an output stream on this system that uses the provided
stream specific serde instead of the default system serde.
An OutputStream<KV<K, V>>
, obtained using a descriptor with a KVSerde<K, V>
, can send messages
of type KV<K, V>
. An OutputStream<M>
with any other Serde<M>
can send messages of
type M without a key.
A KVSerde<NoOpSerde, NoOpSerde>
or NoOpSerde
may be used if the SystemProducer
serializes the outgoing messages itself, and no prior serialization is required from the framework.
StreamMessageType
- type of messages in the output streamstreamId
- id of the output streamserde
- serde for this output stream that overrides the default system serde, if any.OutputDescriptor
for the output stream