DefaultKfTopicRequest

Type Alias DefaultKfTopicRequest 

Source
pub type DefaultKfTopicRequest = TopicProduceData<RecordSet>;

Aliased Type§

pub struct DefaultKfTopicRequest {
    pub name: String,
    pub partitions: Vec<PartitionProduceData<RecordSet>>,
    pub data: PhantomData<RecordSet>,
}

Fields§

§name: String

The topic name.

§partitions: Vec<PartitionProduceData<RecordSet>>

Each partition to produce to.

§data: PhantomData<RecordSet>