Struct NewPartitions 

pub struct NewPartitions { /* private fields */ }

Describes new partitions for a particular topic in a call to Admin::create_partitions.

Corresponds to org.apache.kafka.clients.admin.NewPartitions.

Implementations

impl NewPartitions

pub fn increase_to(total_count: i32) -> Self

Increase the partition count for a topic to the given total_count. The assignment of new replicas to brokers will be decided by the broker.

total_count is the total number of partitions after the operation succeeds.

pub fn increase_to_new_assignments( total_count: i32, new_assignments: Vec<Vec<i32>>, ) -> Self

Increase the partition count for a topic to the given total_count assigning the new partitions according to the given new_assignments.

The length of the given new_assignments should equal total_count - old_count, since the assignment of existing partitions is not changed. Each inner list of new_assignments should have a length equal to the topic’s replication factor. The first broker id in each inner list is the “preferred replica”.

total_count is the total number of partitions after the operation succeeds; new_assignments are the replica assignments for the new partitions.

pub fn total_count(&self) -> i32

The total number of partitions after the operation succeeds.

pub fn assignments(&self) -> Option<&Vec<Vec<i32>>>

The replica assignments for the new partitions, or None if the assignment will be done by the controller.

Trait Implementations

impl Clone for NewPartitions

fn clone(&self) -> NewPartitions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NewPartitions

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

Formats the value using the given formatter.

impl Display for NewPartitions

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

Formats the value using the given formatter.

impl PartialEq for NewPartitions

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Eq for NewPartitions

impl StructuralPartialEq for NewPartitions