Struct Topic 

pub struct Topic {
    pub name: String,
    pub partitions: Vec<Partition>,
    pub config: TopicConfig,
    pub fixtures: Vec<Arc<KafkaFixture>>,
    /* private fields */
}

Represents a Kafka topic

Fields

name: String

partitions: Vec<Partition>

config: TopicConfig

fixtures: Vec<Arc<KafkaFixture>>

Implementations

impl Topic

pub fn new(name: String, config: TopicConfig) -> Self

Create a new topic

pub fn assign_partition(&mut self, key: Option<&[u8]>) -> i32

Assign partition for a message based on key

pub async fn produce( &mut self, partition: i32, record: KafkaMessage, ) -> Result<i64>

Produce a record to the appropriate partition

pub fn get_partition(&self, id: i32) -> Option<&Partition>

Get partition by ID

pub fn get_partition_mut(&mut self, id: i32) -> Option<&mut Partition>

Get mutable partition by ID

Trait Implementations

impl Debug for Topic

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

Formats the value using the given formatter.