public interface TierTopicAppender
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<TierPartitionState.AppendResult> |
addMetadata(AbstractTierMetadata entry)
Write an AbstractTierMetadata to the Tier Topic, returning a
CompletableFuture that tracks the result of the materialization after the
message has been read from the tier topic, allowing the sender to determine
whether the write was fenced, or the send failed.
|
java.util.concurrent.CompletableFuture<TierPartitionState.AppendResult> |
becomeArchiver(TopicIdPartition topicIdPartition,
int tierEpoch)
Performs a write to the tier topic to attempt to become leader for the tiered topic partition.
|
boolean |
isReady()
Return whether TierTopicManager is ready to accept writes.
|
java.util.concurrent.CompletableFuture<TierPartitionState.AppendResult> becomeArchiver(TopicIdPartition topicIdPartition, int tierEpoch) throws java.lang.IllegalAccessException
topicIdPartition
- the topic partition for which the sender wishes to become the
archive leader.tierEpoch
- the archiver epochjava.lang.IllegalAccessException
java.util.concurrent.CompletableFuture<TierPartitionState.AppendResult> addMetadata(AbstractTierMetadata entry) throws java.lang.IllegalAccessException
entry
- the tier topic entry to be written to the tier topic.java.lang.IllegalAccessException
boolean isReady()