pub struct Builder { /* private fields */ }
Expand description
A builder for UpdatePipeSourceManagedStreamingKafkaParameters
.
Implementations§
source§impl Builder
impl Builder
sourcepub fn batch_size(self, input: i32) -> Self
pub fn batch_size(self, input: i32) -> Self
The maximum number of records to include in each batch.
sourcepub fn set_batch_size(self, input: Option<i32>) -> Self
pub fn set_batch_size(self, input: Option<i32>) -> Self
The maximum number of records to include in each batch.
sourcepub fn credentials(self, input: MskAccessCredentials) -> Self
pub fn credentials(self, input: MskAccessCredentials) -> Self
The credentials needed to access the resource.
sourcepub fn set_credentials(self, input: Option<MskAccessCredentials>) -> Self
pub fn set_credentials(self, input: Option<MskAccessCredentials>) -> Self
The credentials needed to access the resource.
sourcepub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
pub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
The maximum length of a time to wait for events.
sourcepub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
pub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
The maximum length of a time to wait for events.
sourcepub fn build(self) -> UpdatePipeSourceManagedStreamingKafkaParameters
pub fn build(self) -> UpdatePipeSourceManagedStreamingKafkaParameters
Consumes the builder and constructs a UpdatePipeSourceManagedStreamingKafkaParameters
.