#[non_exhaustive]pub struct ConsumerGroupReplicationUpdate {
pub consumer_groups_to_exclude: Option<Vec<String>>,
pub consumer_groups_to_replicate: Option<Vec<String>>,
pub detect_and_copy_new_consumer_groups: Option<bool>,
pub synchronise_consumer_group_offsets: Option<bool>,
}
Expand description
Details about consumer group replication.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.consumer_groups_to_exclude: Option<Vec<String>>
List of regular expression patterns indicating the consumer groups that should not be replicated.
consumer_groups_to_replicate: Option<Vec<String>>
List of regular expression patterns indicating the consumer groups to copy.
detect_and_copy_new_consumer_groups: Option<bool>
Enables synchronization of consumer groups to target cluster.
synchronise_consumer_group_offsets: Option<bool>
Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
Implementations§
source§impl ConsumerGroupReplicationUpdate
impl ConsumerGroupReplicationUpdate
sourcepub fn consumer_groups_to_exclude(&self) -> &[String]
pub fn consumer_groups_to_exclude(&self) -> &[String]
List of regular expression patterns indicating the consumer groups that should not be replicated.
If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .consumer_groups_to_exclude.is_none()
.
sourcepub fn consumer_groups_to_replicate(&self) -> &[String]
pub fn consumer_groups_to_replicate(&self) -> &[String]
List of regular expression patterns indicating the consumer groups to copy.
If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .consumer_groups_to_replicate.is_none()
.
sourcepub fn detect_and_copy_new_consumer_groups(&self) -> Option<bool>
pub fn detect_and_copy_new_consumer_groups(&self) -> Option<bool>
Enables synchronization of consumer groups to target cluster.
sourcepub fn synchronise_consumer_group_offsets(&self) -> Option<bool>
pub fn synchronise_consumer_group_offsets(&self) -> Option<bool>
Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
source§impl ConsumerGroupReplicationUpdate
impl ConsumerGroupReplicationUpdate
sourcepub fn builder() -> ConsumerGroupReplicationUpdateBuilder
pub fn builder() -> ConsumerGroupReplicationUpdateBuilder
Creates a new builder-style object to manufacture ConsumerGroupReplicationUpdate
.
Trait Implementations§
source§impl Clone for ConsumerGroupReplicationUpdate
impl Clone for ConsumerGroupReplicationUpdate
source§fn clone(&self) -> ConsumerGroupReplicationUpdate
fn clone(&self) -> ConsumerGroupReplicationUpdate
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl PartialEq for ConsumerGroupReplicationUpdate
impl PartialEq for ConsumerGroupReplicationUpdate
source§fn eq(&self, other: &ConsumerGroupReplicationUpdate) -> bool
fn eq(&self, other: &ConsumerGroupReplicationUpdate) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ConsumerGroupReplicationUpdate
Auto Trait Implementations§
impl Freeze for ConsumerGroupReplicationUpdate
impl RefUnwindSafe for ConsumerGroupReplicationUpdate
impl Send for ConsumerGroupReplicationUpdate
impl Sync for ConsumerGroupReplicationUpdate
impl Unpin for ConsumerGroupReplicationUpdate
impl UnwindSafe for ConsumerGroupReplicationUpdate
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more