public class KafkaSourceOptions extends Object
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
CLIENT_ID_PREFIX |
static ConfigOption<Long> |
PARTITION_DISCOVERY_INTERVAL_MS |
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 <T> T getOption(Properties props, ConfigOption configOption, java.util.function.Function<String,T> parser)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.