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. abstract class MultiSend[S <: Send] extends Send

   

   A set of composite sends, sent one after another

6. trait Receive extends Transmission

   

   A transmission that is being received from a channel

7. class RequestChannel extends KafkaMetricsGroup

   

8. class RequestMetrics extends KafkaMetricsGroup

   

9. trait Send extends Transmission

   

   A transmission that is being sent out to the channel

10. 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 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.

11. class TooManyConnectionsException extends KafkaException