Struct fluvio_dataplane_protocol::produce::ProduceResponse [−][src]
pub struct ProduceResponse { pub responses: Vec<TopicProduceResponse>, pub throttle_time_ms: i32, }
Fields
responses: Vec<TopicProduceResponse>
Each produce response
throttle_time_ms: i32
The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
Implementations
pub fn find_partition_response(
&self,
topic: &str,
partition: i32
) -> Option<&PartitionProduceResponse>
pub fn find_partition_response(
&self,
topic: &str,
partition: i32
) -> Option<&PartitionProduceResponse>
Find partition in Response