Struct DescribeProducersResponse 

pub struct DescribeProducersResponse {
    pub throttle_time_ms: i32,
    pub topics: Vec<DescribeProducersTopic>,
}

DescribeProducers v0 response body. There is no top-level ErrorCode after throttle; the first-partition code is later in the body.

Fields

throttle_time_ms: i32

DescribeProducers ThrottleTimeMs (JSON 0+). First field. JSON default is 0.

topics: Vec<DescribeProducersTopic>

Topics in this request or response.

Implementations

impl DescribeProducersResponse

pub fn new(topics: Vec<DescribeProducersTopic>) -> Self

Construct Self.

pub fn throttle_time_ms(&self) -> i32

DescribeProducers ThrottleTimeMs (JSON 0+).

pub fn topics(&self) -> &[DescribeProducersTopic]

Per-topic producer state.

pub fn error_counts(&self) -> HashMap<i16, i32>

Java DescribeProducersResponse.errorCounts.

Counts partition-level error codes (including NONE). There is no top-level errorCode.

Trait Implementations

impl Clone for DescribeProducersResponse

fn clone(&self) -> DescribeProducersResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DescribeProducersResponse

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

Formats the value using the given formatter.

impl Eq for DescribeProducersResponse

impl PartialEq for DescribeProducersResponse

fn eq(&self, other: &DescribeProducersResponse) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DescribeProducersResponse