send method

Future send(
  1. Broker broker,
  2. KafkaRequest request
)

Sends request to specified Broker.

Implementation

Future<dynamic> send(Broker broker, KafkaRequest request) {
  return _send(broker.host, broker.port, request);
}