Documentation for ruby-kafka (0.4.3)

Alphabetic Index

File Listing

README

Namespace Listing A-Z

A

AsyncProducer (Kafka)
AsyncProducerSubscriber (Kafka::Datadog)
AsyncProducerSubscriber (Kafka::Statsd)

B

Broker (Kafka)
BrokerInfo (Kafka::Protocol::MetadataResponse)
BrokerNotAvailable (Kafka)
BrokerPool (Kafka)
BufferOverflow (Kafka)

C

Client (Kafka)
Cluster (Kafka)
ClusterAuthorizationCode (Kafka)
Compression (Kafka)
Compressor (Kafka)
Connection (Kafka)
ConnectionBuilder (Kafka)
ConnectionError (Kafka)
ConnectionSubscriber (Kafka::Datadog)
ConnectionSubscriber (Kafka::Statsd)
Consumer (Kafka)
ConsumerGroup (Kafka)
ConsumerGroupProtocol (Kafka::Protocol)
ConsumerSubscriber (Kafka::Datadog)
ConsumerSubscriber (Kafka::Statsd)
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

GroupAuthorizationCode (Kafka)
GroupCoordinatorNotAvailable (Kafka)
GroupCoordinatorRequest (Kafka::Protocol)
GroupCoordinatorResponse (Kafka::Protocol)
GzipCodec (Kafka)

H

Heartbeat (Kafka)
HeartbeatError (Kafka)
HeartbeatRequest (Kafka::Protocol)
HeartbeatResponse (Kafka::Protocol)

I

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

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::ListOffsetResponse)
PartitionOffsetInfo (Kafka::Protocol::OffsetFetchResponse)
Partitioner (Kafka)
PendingMessage (Kafka)
PendingMessageQueue (Kafka)
ProcessingError (Kafka)
ProduceOperation (Kafka)
ProduceRequest (Kafka::Protocol)
ProduceResponse (Kafka::Protocol)
Producer (Kafka)
ProducerSubscriber (Kafka::Datadog)
ProducerSubscriber (Kafka::Statsd)
Protocol (Kafka)
ProtocolError (Kafka)

R

S

SSLSocketWithTimeout (Kafka)
SaslAuthenticator (Kafka)
SaslGssapiAuthenticator (Kafka)
SaslHandshakeRequest (Kafka::Protocol)
SaslHandshakeResponse (Kafka::Protocol)
SaslPlainAuthenticator (Kafka)
SnappyCodec (Kafka)
SocketWithTimeout (Kafka)
Statsd (Kafka)
StatsdSubscriber (Kafka::Datadog)
StatsdSubscriber (Kafka::Statsd)
SyncGroupRequest (Kafka::Protocol)
SyncGroupResponse (Kafka::Protocol)

T

Timer (Kafka::AsyncProducer)
TopicAlreadyExists (Kafka)
TopicAuthorizationCode (Kafka)
TopicInfo (Kafka::Protocol::ProduceResponse)
TopicMetadata (Kafka::Protocol::MetadataResponse)
TopicMetadataRequest (Kafka::Protocol)
TopicOffsetInfo (Kafka::Protocol::ListOffsetResponse)

U

W

Worker (Kafka::AsyncProducer)