Producer trait defines the common interface of stream producers.
Clone, so you can use it like an
You can assign custom sharders to Producers. Sharding simply means splitting a stream into multiple keys, in the format of
Send a message to the already anchored stream. This function is non-blocking. You don’t have to
await the future if you are not interested in the
If the producer is not anchored, this will return
If you await the future, you will get a receipt composed of (StreamKey, ShardId, SeqNo, Timestamp). This usually means that the message has been received by the server, but may not guarantee that the message is already persisted.
send, but to the specified stream key.
Flush all pending messages.
End this producer, only after flushing all it's pending messages.
Lock this producer to a particular stream. This function can only be called once. Subsequent calls should return
If the producer is already anchored, return a reference to the StreamKey. If the producer is not anchored, this will return