class Kafka::Broker
def fetch_metadata(**options)
-
(Kafka::Protocol::MetadataResponse)
-
Parameters:
-
(
) --
def fetch_metadata(**options) request = Protocol::MetadataRequest.new(**options) send_request(request) end
(Kafka::Protocol::MetadataResponse)
-
(
)
--
def fetch_metadata(**options) request = Protocol::MetadataRequest.new(**options) send_request(request) end