public static final String |
ALL_TOPICS |
"all" |
public static final String |
AVG_RECORD_MILLIS |
"avg.record.millis" |
public static final String |
BOOTSTRAP_WITH_OFFSET |
"bootstrap.with.offset" |
public static final String |
DEFAULT_BOOTSTRAP_WITH_OFFSET |
"latest" |
public static final String |
DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS |
"org.apache.gobblin.kafka.client.Kafka08ConsumerClient$Factory" |
public static final boolean |
DEFAULT_GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE |
false |
public static final String |
DEFAULT_NAMESPACE_NAME |
"KAFKA" |
public static final String |
DEFAULT_RESET_ON_OFFSET_OUT_OF_RANGE |
"nearest" |
public static final String |
EARLIEST_OFFSET |
"earliest" |
public static final String |
GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS |
"gobblin.kafka.consumerClient.class" |
public static final String |
GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION |
"gobblin.kafka.extract.allowTableTypeAndNamspaceCustomization" |
public static final String |
GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE |
"gobblin.kafka.shouldEnableDatasetStateStore" |
public static final String |
KAFKA_OFFSET_LOOKBACK |
"kafka.offset.lookback" |
public static final String |
LATEST_OFFSET |
"latest" |
public static final String |
LEADER_HOSTANDPORT |
"leader.hostandport" |
public static final String |
LEADER_ID |
"leader.id" |
public static final String |
MAX_POSSIBLE_OBSERVED_LATENCY_IN_HOURS |
"gobblin.kafka.maxobservedLatencyInHours" |
public static final String |
NEAREST_OFFSET |
"nearest" |
public static final String |
NUM_TOPIC_PARTITIONS |
"numTopicPartitions" |
public static final String |
OBSERVED_LATENCY_MEASUREMENT_ENABLED |
"gobblin.kafka.observedLatencyMeasurementEnabled" |
public static final String |
OBSERVED_LATENCY_PRECISION |
"gobblin.kafka.observedLatencyPrecision" |
public static final String |
OFFSET_FETCH_EPOCH_TIME |
"offsetFetchEpochTime" |
public static final String |
OFFSET_FETCH_TIMER |
"offsetFetchTimer" |
public static final String |
OFFSET_LOOKBACK |
"offset_lookback" |
public static final String |
PARTITION_ID |
"partition.id" |
public static final String |
PREVIOUS_HIGH_WATERMARK |
"previousHighWatermark" |
public static final String |
PREVIOUS_LATEST_OFFSET |
"previousLatestOffset" |
public static final String |
PREVIOUS_LOW_WATERMARK |
"previousLowWatermark" |
public static final String |
PREVIOUS_OFFSET_FETCH_EPOCH_TIME |
"previousOffsetFetchEpochTime" |
public static final String |
PREVIOUS_START_FETCH_EPOCH_TIME |
"previousStartFetchEpochTime" |
public static final String |
PREVIOUS_STOP_FETCH_EPOCH_TIME |
"previousStopFetchEpochTime" |
public static final String |
RECORD_CREATION_TIMESTAMP_FIELD |
"gobblin.kafka.recordCreationTimestampField" |
public static final String |
RECORD_CREATION_TIMESTAMP_UNIT |
"gobblin.kafka.recordCreationTimestampUnit" |
public static final String |
RECORD_LEVEL_SLA_MINUTES_KEY |
"gobblin.kafka.recordLevelSlaMinutes" |
public static final String |
RESET_ON_OFFSET_OUT_OF_RANGE |
"reset.on.offset.out.of.range" |
public static final String |
START_FETCH_EPOCH_TIME |
"startFetchEpochTime" |
public static final String |
STOP_FETCH_EPOCH_TIME |
"stopFetchEpochTime" |
public static final String |
TOPIC_BLACKLIST |
"topic.blacklist" |
public static final String |
TOPIC_NAME |
"topic.name" |
public static final String |
TOPIC_WHITELIST |
"topic.whitelist" |
public static final String |
TOPICS_MOVE_TO_LATEST_OFFSET |
"topics.move.to.latest.offset" |