Struct Topic 

#[non_exhaustive]
pub struct Topic {
    pub name: String,
    pub partition_count: i32,
    pub replication_factor: i32,
    pub configs: HashMap<String, String>,
    /* private fields */
}

A Kafka topic in a given cluster.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

name: String

Identifier. The name of the topic. The topic segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}

partition_count: i32

Required. The number of partitions this topic has. The partition count can only be increased, not decreased. Please note that if partitions are increased for a topic that has a key, the partitioning logic or the ordering of the messages will be affected.

replication_factor: i32

Required. Immutable. The number of replicas of each partition. A replication factor of 3 is recommended for high availability.

configs: HashMap<String, String>

Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: cleanup.policy, compression.type.

Implementations

impl Topic

pub fn new() -> Self

pub fn set_name<T: Into<String>>(self, v: T) -> Self

Sets the value of name.

pub fn set_partition_count<T: Into<i32>>(self, v: T) -> Self

Sets the value of partition_count.

pub fn set_replication_factor<T: Into<i32>>(self, v: T) -> Self

Sets the value of replication_factor.

pub fn set_configs<T, K, V>(self, v: T) -> Self

where T: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<String>,

Sets the value of configs.

Trait Implementations

impl Clone for Topic

fn clone(&self) -> Topic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Topic

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

Formats the value using the given formatter.

impl Default for Topic

fn default() -> Topic

Returns the “default value” for a type.

impl Message for Topic

fn typename() -> &'static str

The typename of this message.

impl PartialEq for Topic

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