-
Request to deliver the message only after the specified relative delay.
TypedMessageBuilder.deliverAt(long timestamp)
Deliver the message only at or after the specified absolute timestamp.
Disable geo-replication for this message.
TypedMessageBuilder.eventTime(long timestamp)
Set the event time for a given message.
Sets the key of the message for routing policy.
TypedMessageBuilder.keyBytes(byte[] key)
Sets the bytes of the key of the message for routing policy.
Configure the
TypedMessageBuilder
from a config map, as an alternative compared
to call the individual builder methods.
Create a new message builder.
Create a new message builder with schema, not required same parameterized type with the producer.
Create a new message builder with transaction.
Add all the properties in the provided map.
Sets a new property on a message.
Override the geo-replication clusters for this message.
Specify a custom sequence id for the message being published.
TypedMessageBuilder.value(T value)
Set a domain object on the message.