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

  11. class TooManyConnectionsException extends KafkaException

Value Members

  1. object BlockingChannel

  2. object RequestChannel extends Logging

  3. object RequestMetrics

Ungrouped