public class TierTopicMaterializationToolConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BOOTSTRAP_SERVER_CONFIG |
static java.lang.String |
BOOTSTRAP_SERVER_DOC |
static java.lang.String |
DUMP_EVENTS |
static java.lang.String |
DUMP_EVENTS_DOC |
static java.lang.String |
DUMP_METADATA |
static java.lang.String |
DUMP_METADATA_DOC |
static java.lang.String |
DUMP_METADATA_HEADER |
static java.lang.String |
DUMP_METADATA_HEADER_DOC |
java.lang.Boolean |
dumpEvents |
java.lang.Boolean |
dumpHeader |
java.lang.Boolean |
dumpRecords |
static java.util.UUID |
EMPTY_UUID |
static java.lang.String |
EMPTY_UUID_STR |
static java.lang.String |
END_OFFSET |
static java.lang.String |
END_OFFSET_DOC |
java.lang.Integer |
endOffset |
java.lang.String |
materializationPath |
java.lang.Boolean |
materialize |
static java.lang.String |
MATERIALIZE |
static java.lang.String |
MATERIALIZE_DOC |
static java.lang.String |
METADATA_STATES_DIR |
static java.lang.String |
METADATA_STATES_DIR_DOC |
java.lang.String |
metadataStatesDir |
java.lang.Integer |
partition |
java.lang.String |
server |
static java.lang.String |
SRC_PARTIITON_DOC |
static java.lang.String |
SRC_PARTITION |
static java.lang.String |
SRC_TOPIC_DOC |
static java.lang.String |
SRC_TOPIC_ID |
static java.lang.String |
START_OFFSET |
static java.lang.String |
START_OFFSET_DOC |
java.lang.Integer |
startOffset |
static java.lang.String |
TIER_STATE_TOPIC_PARTITION |
static java.lang.String |
TIER_STATE_TOPIC_PARTITION_DOC |
java.lang.Integer |
userPartition |
java.util.UUID |
userTopicId |
static java.lang.String |
WORKING_DIR |
static java.lang.String |
WORKING_DIR_DOC |
Constructor and Description |
---|
TierTopicMaterializationToolConfig(java.util.Properties props) |
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String SRC_TOPIC_ID
public static final java.lang.String SRC_TOPIC_DOC
public static final java.lang.String SRC_PARTITION
public static final java.lang.String SRC_PARTIITON_DOC
public static final java.lang.String TIER_STATE_TOPIC_PARTITION
public static final java.lang.String TIER_STATE_TOPIC_PARTITION_DOC
public static final java.lang.String START_OFFSET
public static final java.lang.String START_OFFSET_DOC
public static final java.lang.String END_OFFSET
public static final java.lang.String END_OFFSET_DOC
public static final java.lang.String BOOTSTRAP_SERVER_CONFIG
public static final java.lang.String BOOTSTRAP_SERVER_DOC
public static final java.lang.String DUMP_METADATA
public static final java.lang.String DUMP_METADATA_DOC
public static final java.lang.String DUMP_METADATA_HEADER
public static final java.lang.String DUMP_METADATA_HEADER_DOC
public static final java.lang.String WORKING_DIR
public static final java.lang.String WORKING_DIR_DOC
public static final java.lang.String METADATA_STATES_DIR
public static final java.lang.String METADATA_STATES_DIR_DOC
public static final java.lang.String EMPTY_UUID_STR
public static final java.util.UUID EMPTY_UUID
public static final java.lang.String DUMP_EVENTS
public static final java.lang.String DUMP_EVENTS_DOC
public static final java.lang.String MATERIALIZE
public static final java.lang.String MATERIALIZE_DOC
public final java.lang.Integer userPartition
public final java.lang.Integer partition
public final java.lang.Integer startOffset
public final java.lang.Integer endOffset
public final java.lang.String server
public final java.lang.Boolean dumpRecords
public final java.util.UUID userTopicId
public final java.lang.String materializationPath
public final java.lang.Boolean dumpHeader
public final java.lang.String metadataStatesDir
public final java.lang.Boolean dumpEvents
public final java.lang.Boolean materialize