Struct aws_sdk_glue::model::kafka_streaming_source_options::Builder

pub struct Builder { /* private fields */ }

A builder for KafkaStreamingSourceOptions.

Implementations

impl Builder

pub fn bootstrap_servers(self, input: impl Into<String>) -> Self

A list of bootstrap server URLs, for example, as b-1.vpc-test-2.o4q88o.c6.kafka.us-east-1.amazonaws.com:9094. This option must be specified in the API call or defined in the table metadata in the Data Catalog.

pub fn set_bootstrap_servers(self, input: Option<String>) -> Self

A list of bootstrap server URLs, for example, as b-1.vpc-test-2.o4q88o.c6.kafka.us-east-1.amazonaws.com:9094. This option must be specified in the API call or defined in the table metadata in the Data Catalog.

pub fn security_protocol(self, input: impl Into<String>) -> Self

The protocol used to communicate with brokers. The possible values are "SSL" or "PLAINTEXT".

pub fn set_security_protocol(self, input: Option<String>) -> Self

The protocol used to communicate with brokers. The possible values are "SSL" or "PLAINTEXT".

pub fn connection_name(self, input: impl Into<String>) -> Self

The name of the connection.

pub fn set_connection_name(self, input: Option<String>) -> Self

The name of the connection.

pub fn topic_name(self, input: impl Into<String>) -> Self

The topic name as specified in Apache Kafka. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn set_topic_name(self, input: Option<String>) -> Self

The topic name as specified in Apache Kafka. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn assign(self, input: impl Into<String>) -> Self

The specific TopicPartitions to consume. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn set_assign(self, input: Option<String>) -> Self

The specific TopicPartitions to consume. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn subscribe_pattern(self, input: impl Into<String>) -> Self

A Java regex string that identifies the topic list to subscribe to. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn set_subscribe_pattern(self, input: Option<String>) -> Self

A Java regex string that identifies the topic list to subscribe to. You must specify at least one of "topicName", "assign" or "subscribePattern".

pub fn classification(self, input: impl Into<String>) -> Self

An optional classification.

pub fn set_classification(self, input: Option<String>) -> Self

An optional classification.

pub fn delimiter(self, input: impl Into<String>) -> Self

Specifies the delimiter character.

pub fn set_delimiter(self, input: Option<String>) -> Self

Specifies the delimiter character.

pub fn starting_offsets(self, input: impl Into<String>) -> Self

The starting position in the Kafka topic to read data from. The possible values are "earliest" or "latest". The default value is "latest".

pub fn set_starting_offsets(self, input: Option<String>) -> Self

The starting position in the Kafka topic to read data from. The possible values are "earliest" or "latest". The default value is "latest".

pub fn ending_offsets(self, input: impl Into<String>) -> Self

The end point when a batch query is ended. Possible values are either "latest" or a JSON string that specifies an ending offset for each TopicPartition.

pub fn set_ending_offsets(self, input: Option<String>) -> Self

The end point when a batch query is ended. Possible values are either "latest" or a JSON string that specifies an ending offset for each TopicPartition.

pub fn poll_timeout_ms(self, input: i64) -> Self

The timeout in milliseconds to poll data from Kafka in Spark job executors. The default value is 512.

pub fn set_poll_timeout_ms(self, input: Option<i64>) -> Self

The timeout in milliseconds to poll data from Kafka in Spark job executors. The default value is 512.

pub fn num_retries(self, input: i32) -> Self

The number of times to retry before failing to fetch Kafka offsets. The default value is 3.

pub fn set_num_retries(self, input: Option<i32>) -> Self

The number of times to retry before failing to fetch Kafka offsets. The default value is 3.

pub fn retry_interval_ms(self, input: i64) -> Self

The time in milliseconds to wait before retrying to fetch Kafka offsets. The default value is 10.

pub fn set_retry_interval_ms(self, input: Option<i64>) -> Self

The time in milliseconds to wait before retrying to fetch Kafka offsets. The default value is 10.

pub fn max_offsets_per_trigger(self, input: i64) -> Self

The rate limit on the maximum number of offsets that are processed per trigger interval. The specified total number of offsets is proportionally split across topicPartitions of different volumes. The default value is null, which means that the consumer reads all offsets until the known latest offset.

pub fn set_max_offsets_per_trigger(self, input: Option<i64>) -> Self

The rate limit on the maximum number of offsets that are processed per trigger interval. The specified total number of offsets is proportionally split across topicPartitions of different volumes. The default value is null, which means that the consumer reads all offsets until the known latest offset.

pub fn min_partitions(self, input: i32) -> Self

The desired minimum number of partitions to read from Kafka. The default value is null, which means that the number of spark partitions is equal to the number of Kafka partitions.

pub fn set_min_partitions(self, input: Option<i32>) -> Self

The desired minimum number of partitions to read from Kafka. The default value is null, which means that the number of spark partitions is equal to the number of Kafka partitions.

pub fn build(self) -> KafkaStreamingSourceOptions

Consumes the builder and constructs a KafkaStreamingSourceOptions.

Trait Implementations

impl Clone for Builder

fn clone(&self) -> Builder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Builder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Builder

fn default() -> Builder

Returns the “default value” for a type.

impl PartialEq<Builder> for Builder

fn eq(&self, other: &Builder) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Builder