Struct NewTopic 

pub struct NewTopic { /* private fields */ }

A new topic to be created via Admin::create_topics.

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

replicas_assignments and configs use BTreeMap (rather than HashMap) so that conversion to the wire request is deterministically ordered — Java iterates its Map in unspecified order, but a stable order simplifies wire-byte comparison and testing.

Implementations

impl NewTopic

pub fn with_num_partitions_replication_factor( name: impl Into<String>, num_partitions: Option<i32>, replication_factor: Option<i16>, ) -> Self

A new topic with the specified replication factor and number of partitions, either of which optionally defaults to the broker configurations for num.partitions and default.replication.factor respectively.

Translates both of Java’s first two constructors: NewTopic(String, int, short) (NewTopic.java:47) and NewTopic(String, Optional<Integer>, Optional<Short>) (:56). They differ only by the Optional wrapper — :47’s body is literally this(name, Optional.of(numPartitions), Optional.of(replicationFactor)) — so under CLAUDE.md §2 (“in case the difference is only Optional use Rust’s Option and a single method name”) they are one Rust method taking Option. Callers of the former pass Some(..).

The surviving group is {name, num_partitions, replication_factor} and {name, replicas_assignments}, whose intersection is {name}. No constructor takes name alone, so under §2 nobody keeps the plain new and both carry a parameter-name suffix.

pub fn with_replicas_assignments( name: impl Into<String>, replicas_assignments: BTreeMap<i32, Vec<i32>>, ) -> Self

A new topic with the specified replica assignment configuration.

• name - the topic name
• replicas_assignments - a map from partition id to replica ids (i.e. broker ids). The first replica is treated as the preferred leader.

pub fn name(&self) -> &str

The name of the topic to be created.

pub fn num_partitions(&self) -> i32

The number of partitions for the new topic or -1 if a replica assignment has been specified.

pub fn replication_factor(&self) -> i16

The replication factor for the new topic or -1 if a replica assignment has been specified.

pub fn replicas_assignments(&self) -> Option<&BTreeMap<i32, Vec<i32>>>

A map from partition id to replica ids (i.e. broker ids) or None if the number of partitions and replication factor have been specified instead.

pub fn set_configs(self, configs: BTreeMap<String, String>) -> Self

Set the configuration to use on the new topic. Returns self for chaining, mirroring Java’s fluent configs(...).

pub fn configs(&self) -> Option<&BTreeMap<String, String>>

The configuration for the new topic or None if no configs were ever specified.

Trait Implementations

impl Clone for NewTopic

fn clone(&self) -> NewTopic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NewTopic

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

Formats the value using the given formatter.

impl Display for NewTopic

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

Formats the value using the given formatter.

impl PartialEq for NewTopic

fn eq(&self, other: &NewTopic) -> 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 NewTopic

impl StructuralPartialEq for NewTopic