public class TierPartitionStateFencingTrigger
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FILE_FENCE_TARGET_PARTITIONS_CONFIG |
static java.lang.String |
FILE_FENCE_TARGET_PARTITIONS_DOC |
static java.lang.String |
OUTPUT_CONFIG |
static java.lang.String |
OUTPUT_CONFIG_DOC |
static java.util.List<java.lang.String> |
REQUIRED_PROPERTIES |
Constructor and Description |
---|
TierPartitionStateFencingTrigger() |
Modifier and Type | Method and Description |
---|---|
static java.util.List<FenceEventInfo> |
injectFencingEvents(java.util.Properties properties,
java.lang.String tierTopicNamespace,
java.util.List<TopicIdPartition> tieredTopicIdPartitions) |
static void |
main(java.lang.String[] args) |
public static final java.util.List<java.lang.String> REQUIRED_PROPERTIES
public static final java.lang.String FILE_FENCE_TARGET_PARTITIONS_CONFIG
public static final java.lang.String FILE_FENCE_TARGET_PARTITIONS_DOC
public static final java.lang.String OUTPUT_CONFIG
public static final java.lang.String OUTPUT_CONFIG_DOC
public static java.util.List<FenceEventInfo> injectFencingEvents(java.util.Properties properties, java.lang.String tierTopicNamespace, java.util.List<TopicIdPartition> tieredTopicIdPartitions) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception