Uses of Class
org.apache.flink.connector.kafka.source.KafkaSourceBuilder

Packages that use KafkaSourceBuilder

Package	Description
org.apache.flink.connector.kafka.source

Uses of KafkaSourceBuilder in org.apache.flink.connector.kafka.source

Methods in org.apache.flink.connector.kafka.source that return KafkaSourceBuilder

Modifier and Type	Method and Description
static <OUT> KafkaSourceBuilder<OUT>	KafkaSource.builder() Get a kafkaSourceBuilder to build a KafkaSource.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setBootstrapServers(String bootstrapServers) Sets the bootstrap servers for the KafkaConsumer of the KafkaSource.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setBounded(OffsetsInitializer stoppingOffsetsInitializer) By default the KafkaSource is set to run in Boundedness.CONTINUOUS_UNBOUNDED manner and thus never stops until the Flink job fails or is canceled.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setClientIdPrefix(String prefix) Sets the client id prefix of this KafkaSource.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setDeserializer(KafkaRecordDeserializationSchema<OUT> recordDeserializer) Sets the deserializer of the ConsumerRecord for KafkaSource.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setGroupId(String groupId) Sets the consumer group id of the KafkaSource.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setKafkaSubscriber(KafkaSubscriber kafkaSubscriber) Set a custom Kafka subscriber to use to discover new splits.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setPartitions(Set<org.apache.kafka.common.TopicPartition> partitions) Set a set of partitions to consume from.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setProperties(Properties props) Set arbitrary properties for the KafkaSource and KafkaConsumer.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setProperty(String key, String value) Set an arbitrary property for the KafkaSource and KafkaConsumer.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setStartingOffsets(OffsetsInitializer startingOffsetsInitializer) Specify from which offsets the KafkaSource should start consume from by providing an OffsetsInitializer.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setTopicPattern(Pattern topicPattern) Set a topic pattern to consume from use the java Pattern.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setTopics(List<String> topics) Set a list of topics the KafkaSource should consume from.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setTopics(String... topics) Set a list of topics the KafkaSource should consume from.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setUnbounded(OffsetsInitializer stoppingOffsetsInitializer) By default the KafkaSource is set to run in Boundedness.CONTINUOUS_UNBOUNDED manner and thus never stops until the Flink job fails or is canceled.
KafkaSourceBuilder<OUT>	KafkaSourceBuilder.setValueOnlyDeserializer(DeserializationSchema<OUT> deserializationSchema) Sets the deserializer of the ConsumerRecord for KafkaSource.