kafka
network
package
network
Visibility
Public
All
Type Members
class
BlockingChannel
extends
Logging
A simple blocking channel with timeouts correctly enabled.
trait
ConnectionConfig
extends
AnyRef
class
ConnectionQuotas
extends
AnyRef
class
InvalidRequestException
extends
RuntimeException
class
RequestChannel
extends
KafkaMetricsGroup
class
RequestMetrics
extends
KafkaMetricsGroup
class
RequestOrResponseSend
extends
NetworkSend
with
Logging
class
SocketServer
extends
Logging
with
KafkaMetricsGroup
An NIO socket server.
class
TooManyConnectionsException
extends
KafkaException
Value Members
object
BlockingChannel
object
RequestChannel
extends
Logging
object
RequestMetrics
object
RequestOrResponseSend
Ungrouped