network

Type Members

1. class BlockingChannel extends Logging

   

   A simple blocking channel with timeouts correctly enabled.

   A simple blocking channel with timeouts correctly enabled.

   Annotations

   @nonthreadsafe()

2. trait ConnectionConfig extends AnyRef

   

3. class ConnectionQuotas extends AnyRef

   

4. class InvalidRequestException extends RuntimeException

   

5. class RequestChannel extends KafkaMetricsGroup

   

6. class RequestMetrics extends KafkaMetricsGroup

   

7. class RequestOrResponseSend extends NetworkSend with Logging

   

8. class SocketServer extends Logging with KafkaMetricsGroup

   

   An NIO socket server.

   An NIO socket server. The threading model is 1 Acceptor thread that handles new connections Acceptor has N Processor threads that each have their own selector and read requests from sockets M Handler threads that handle requests and produce responses back to the processor threads for writing.

9. class TooManyConnectionsException extends KafkaException