Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
CLIENT_ID_PREFIX |
static ConfigOption<Boolean> |
COMMIT_OFFSETS_ON_CHECKPOINT |
static ConfigOption<Long> |
PARTITION_DISCOVERY_INTERVAL_MS |
static ConfigOption<Boolean> |
REGISTER_KAFKA_CONSUMER_METRICS |
Constructor and Description |
---|
KafkaSourceOptions() |
Modifier and Type | Method and Description |
---|---|
static <T> T |
getOption(Properties props,
ConfigOption<?> configOption,
java.util.function.Function<String,T> parser) |
public static final ConfigOption<String> CLIENT_ID_PREFIX
public static final ConfigOption<Long> PARTITION_DISCOVERY_INTERVAL_MS
public static final ConfigOption<Boolean> REGISTER_KAFKA_CONSUMER_METRICS
public static final ConfigOption<Boolean> COMMIT_OFFSETS_ON_CHECKPOINT
public static <T> T getOption(Properties props, ConfigOption<?> configOption, java.util.function.Function<String,T> parser)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.