kafka

network

package network

Visibility
  1. Public
  2. All

Type Members

  1. class BlockingChannel extends Logging

    A simple blocking channel with timeouts correctly enabled.

  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.

  9. class TooManyConnectionsException extends KafkaException

Value Members

  1. object BlockingChannel

  2. object RequestChannel extends Logging

  3. object RequestMetrics

  4. object RequestOrResponseSend

Ungrouped