Libraries
»
ruby-kafka
(0.3.14)
»
Documentation for ruby-kafka (0.3.14)
Alphabetic Index
File Listing
README
Namespace Listing A-Z
A
AsyncProducer
(Kafka)
AsyncProducerSubscriber
(Kafka::Datadog)
B
Broker
(Kafka)
BrokerInfo
(Kafka::Protocol::MetadataResponse)
BrokerNotAvailable
(Kafka)
BrokerPool
(Kafka)
BufferOverflow
(Kafka)
C
Client
(Kafka)
Cluster
(Kafka)
Compression
(Kafka)
Compressor
(Kafka)
Connection
(Kafka)
ConnectionBuilder
(Kafka)
ConnectionError
(Kafka)
ConnectionSubscriber
(Kafka::Datadog)
Consumer
(Kafka)
ConsumerGroup
(Kafka)
ConsumerGroupProtocol
(Kafka::Protocol)
ConsumerSubscriber
(Kafka::Datadog)
CorruptMessage
(Kafka)
D
Datadog
(Kafka)
Decoder
(Kafka::Protocol)
DecoratingInstrumenter
(Kafka)
DeliveryFailed
(Kafka)
E
Encoder
(Kafka::Protocol)
Error
(Kafka)
F
FetchError
(Kafka)
FetchOperation
(Kafka)
FetchRequest
(Kafka::Protocol)
FetchResponse
(Kafka::Protocol)
FetchedBatch
(Kafka)
FetchedMessage
(Kafka)
FetchedPartition
(Kafka::Protocol::FetchResponse)
FetchedTopic
(Kafka::Protocol::FetchResponse)
G
GroupCoordinatorNotAvailable
(Kafka)
GroupCoordinatorRequest
(Kafka::Protocol)
GroupCoordinatorResponse
(Kafka::Protocol)
GzipCodec
(Kafka)
H
Heartbeat
(Kafka)
HeartbeatError
(Kafka)
HeartbeatRequest
(Kafka::Protocol)
HeartbeatResponse
(Kafka::Protocol)
I
IllegalGeneration
(Kafka)
Instrumenter
(Kafka)
InvalidMessageSize
(Kafka)
InvalidRequiredAcks
(Kafka)
InvalidSessionTimeout
(Kafka)
InvalidTopic
(Kafka)
J
JoinGroupRequest
(Kafka::Protocol)
JoinGroupResponse
(Kafka::Protocol)
K
Kafka
L
LeaderNotAvailable
(Kafka)
LeaveGroupRequest
(Kafka::Protocol)
LeaveGroupResponse
(Kafka::Protocol)
ListOffsetRequest
(Kafka::Protocol)
ListOffsetResponse
(Kafka::Protocol)
M
MemberAssignment
(Kafka::Protocol)
Message
(Kafka::Protocol)
MessageBuffer
(Kafka)
MessageSet
(Kafka::Protocol)
MessageSizeTooLarge
(Kafka)
MetadataResponse
(Kafka::Protocol)
N
NotCoordinatorForGroup
(Kafka)
NotEnoughReplicas
(Kafka)
NotEnoughReplicasAfterAppend
(Kafka)
NotLeaderForPartition
(Kafka)
O
OffsetCommitError
(Kafka)
OffsetCommitRequest
(Kafka::Protocol)
OffsetCommitResponse
(Kafka::Protocol)
OffsetFetchRequest
(Kafka::Protocol)
OffsetFetchResponse
(Kafka::Protocol)
OffsetManager
(Kafka)
OffsetMetadataTooLarge
(Kafka)
OffsetOutOfRange
(Kafka)
P
PartitionInfo
(Kafka::Protocol::ProduceResponse)
PartitionMetadata
(Kafka::Protocol::MetadataResponse)
PartitionOffsetInfo
(Kafka::Protocol::OffsetFetchResponse)
PartitionOffsetInfo
(Kafka::Protocol::ListOffsetResponse)
Partitioner
(Kafka)
PendingMessage
(Kafka)
PendingMessageQueue
(Kafka)
ProduceOperation
(Kafka)
ProduceRequest
(Kafka::Protocol)
ProduceResponse
(Kafka::Protocol)
Producer
(Kafka)
ProducerSubscriber
(Kafka::Datadog)
Protocol
(Kafka)
ProtocolError
(Kafka)
R
RebalanceInProgress
(Kafka)
RecordListTooLarge
(Kafka)
ReplicaNotAvailable
(Kafka)
RequestMessage
(Kafka::Protocol)
RequestTimedOut
(Kafka)
RoundRobinAssignmentStrategy
(Kafka)
S
SSLSocketWithTimeout
(Kafka)
SnappyCodec
(Kafka)
SocketWithTimeout
(Kafka)
StatsdSubscriber
(Kafka::Datadog)
SyncGroupRequest
(Kafka::Protocol)
SyncGroupResponse
(Kafka::Protocol)
T
Timer
(Kafka::AsyncProducer)
TopicInfo
(Kafka::Protocol::ProduceResponse)
TopicMetadata
(Kafka::Protocol::MetadataResponse)
TopicMetadataRequest
(Kafka::Protocol)
TopicOffsetInfo
(Kafka::Protocol::ListOffsetResponse)
U
UnknownError
(Kafka)
UnknownMemberId
(Kafka)
UnknownTopicOrPartition
(Kafka)
W
Worker
(Kafka::AsyncProducer)