Libraries
»
ruby-kafka
(0.1.7)
»
Documentation for ruby-kafka (0.1.7)
Alphabetic Index
File Listing
README
Namespace Listing A-Z
A
AsyncProducer
(Kafka)
B
Broker
(Kafka)
BrokerInfo
(Kafka::Protocol::MetadataResponse)
BrokerNotAvailable
(Kafka)
BrokerPool
(Kafka)
BufferOverflow
(Kafka)
C
Client
(Kafka)
Cluster
(Kafka)
Compression
(Kafka)
Connection
(Kafka)
ConnectionError
(Kafka)
CorruptMessage
(Kafka)
D
Decoder
(Kafka::Protocol)
DeliveryFailed
(Kafka)
E
Encoder
(Kafka::Protocol)
Error
(Kafka)
F
FetchOperation
(Kafka)
FetchRequest
(Kafka::Protocol)
FetchResponse
(Kafka::Protocol)
FetchedMessage
(Kafka)
FetchedPartition
(Kafka::Protocol::FetchResponse)
FetchedTopic
(Kafka::Protocol::FetchResponse)
G
GzipCodec
(Kafka)
I
InvalidMessageSize
(Kafka)
InvalidRequiredAcks
(Kafka)
InvalidTopic
(Kafka)
K
Kafka
L
LeaderNotAvailable
(Kafka)
ListOffsetRequest
(Kafka::Protocol)
ListOffsetResponse
(Kafka::Protocol)
M
Message
(Kafka::Protocol)
MessageBuffer
(Kafka)
MessageSet
(Kafka::Protocol)
MessageSizeTooLarge
(Kafka)
MetadataResponse
(Kafka::Protocol)
N
NotEnoughReplicas
(Kafka)
NotEnoughReplicasAfterAppend
(Kafka)
NotLeaderForPartition
(Kafka)
NullInstrumentation
(Kafka)
O
OffsetMetadataTooLarge
(Kafka)
OffsetOutOfRange
(Kafka)
P
PartitionInfo
(Kafka::Protocol::ProduceResponse)
PartitionMetadata
(Kafka::Protocol::MetadataResponse)
PartitionOffsetInfo
(Kafka::Protocol::ListOffsetResponse)
Partitioner
(Kafka)
PendingMessage
(Kafka)
PendingMessageQueue
(Kafka)
ProduceOperation
(Kafka)
ProduceRequest
(Kafka::Protocol)
ProduceResponse
(Kafka::Protocol)
Producer
(Kafka)
Protocol
(Kafka)
ProtocolError
(Kafka)
R
RecordListTooLarge
(Kafka)
ReplicaNotAvailable
(Kafka)
RequestMessage
(Kafka::Protocol)
RequestTimedOut
(Kafka)
S
SnappyCodec
(Kafka)
SocketWithTimeout
(Kafka)
T
Timer
(Kafka::AsyncProducer)
TopicInfo
(Kafka::Protocol::ProduceResponse)
TopicMetadata
(Kafka::Protocol::MetadataResponse)
TopicMetadataRequest
(Kafka::Protocol)
TopicOffsetInfo
(Kafka::Protocol::ListOffsetResponse)
U
UnknownError
(Kafka)
UnknownTopicOrPartition
(Kafka)
W
Worker
(Kafka::AsyncProducer)