address
BrokerReportedFailure BrokerRequestFailure InvalidBrokerResponse UnexpectedResponse
apply
KafkaClient BrokerConnection