Documentation for ruby-kafka (1.4.0)

Alphabetic Index

File Listing

README

Namespace Listing A-Z

A

AbortTransaction (Kafka::Producer)
AbortedTransaction (Kafka::Protocol::FetchResponse)
AddOffsetsToTxnRequest (Kafka::Protocol)
AddOffsetsToTxnResponse (Kafka::Protocol)
AddPartitionsToTxnRequest (Kafka::Protocol)
AddPartitionsToTxnResponse (Kafka::Protocol)
AlterConfigsRequest (Kafka::Protocol)
AlterConfigsResponse (Kafka::Protocol)
ApiInfo (Kafka::Protocol::ApiVersionsResponse)
ApiVersionsRequest (Kafka::Protocol)
ApiVersionsResponse (Kafka::Protocol)
Assignor (Kafka::ConsumerGroup)
AsyncProducer (Kafka)
AsyncProducerSubscriber (Kafka::Datadog)
AsyncProducerSubscriber (Kafka::Statsd)
AsyncProducerSubscriber (Kafka::Prometheus)

B

Broker (Kafka)
BrokerInfo (Kafka)
BrokerNotAvailable (Kafka)
BrokerPool (Kafka)
BrokerUri (Kafka)
BufferOverflow (Kafka)

C

Client (Kafka)
Cluster (Kafka)
ClusterAuthorizationFailed (Kafka)
Compression (Kafka)
Compressor (Kafka)
ConcurrentTransactionError (Kafka)
ConfigEntry (Kafka::Protocol::DescribeConfigsResponse)
Connection (Kafka)
ConnectionBuilder (Kafka)
ConnectionError (Kafka)
ConnectionSubscriber (Kafka::Prometheus)
ConnectionSubscriber (Kafka::Statsd)
ConnectionSubscriber (Kafka::Datadog)
Consumer (Kafka)
ConsumerGroup (Kafka)
ConsumerGroupProtocol (Kafka::Protocol)
ConsumerSubscriber (Kafka::Datadog)
ConsumerSubscriber (Kafka::Statsd)
ConsumerSubscriber (Kafka::Prometheus)
CoordinatorLoadInProgress (Kafka)
CoordinatorNotAvailable (Kafka)
CorruptMessage (Kafka)
Crc32Hash (Kafka)
CreatePartitionsRequest (Kafka::Protocol)
CreatePartitionsResponse (Kafka::Protocol)
CreateTopicsRequest (Kafka::Protocol)
CreateTopicsResponse (Kafka::Protocol)

D

Datadog (Kafka)
Decoder (Kafka::Protocol)
DecoratingInstrumenter (Kafka)
DeleteTopicsRequest (Kafka::Protocol)
DeleteTopicsResponse (Kafka::Protocol)
DeliveryFailed (Kafka)
DescribeConfigsRequest (Kafka::Protocol)
DescribeConfigsResponse (Kafka::Protocol)
DescribeGroupsRequest (Kafka::Protocol)
DescribeGroupsResponse (Kafka::Protocol)
Digest (Kafka)
DuplicateSequenceNumberError (Kafka)

E

Encoder (Kafka::Protocol)
EndTxnRequest (Kafka::Protocol)
EndTxnResposne (Kafka::Protocol)
Error (Kafka)

F

FailedScramAuthentication (Kafka)
FetchError (Kafka)
FetchOperation (Kafka)
FetchRequest (Kafka::Protocol)
FetchResponse (Kafka::Protocol)
FetchedBatch (Kafka)
FetchedBatchGenerator (Kafka)
FetchedMessage (Kafka)
FetchedOffsetResolver (Kafka)
FetchedPartition (Kafka::Protocol::FetchResponse)
FetchedTopic (Kafka::Protocol::FetchResponse)
Fetcher (Kafka)
FetcherSubscriber (Kafka::Datadog)
FetcherSubscriber (Kafka::Statsd)
FetcherSubscriber (Kafka::Prometheus)
FindCoordinatorRequest (Kafka::Protocol)
FindCoordinatorResponse (Kafka::Protocol)

G

Group (Kafka::Protocol::DescribeGroupsResponse)
GroupAuthorizationFailed (Kafka)
GroupEntry (Kafka::Protocol::ListGroupsResponse)
Gssapi (Kafka::Sasl)
GzipCodec (Kafka)

H

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

I

IdleConnection (Kafka)
IllegalGeneration (Kafka)
InconsistentGroupProtocol (Kafka)
InitProducerIDRequest (Kafka::Protocol)
InitProducerIDResponse (Kafka::Protocol)
Instrumenter (Kafka)
InsufficientDataMessage (Kafka)
Interceptors (Kafka)
InvalidCommitOffsetSize (Kafka)
InvalidConfig (Kafka)
InvalidGroupId (Kafka)
InvalidMessageSize (Kafka)
InvalidPartitions (Kafka)
InvalidProducerEpochError (Kafka)
InvalidProducerIDMappingError (Kafka)
InvalidReplicaAssignment (Kafka)
InvalidReplicationFactor (Kafka)
InvalidRequest (Kafka)
InvalidRequiredAcks (Kafka)
InvalidSaslState (Kafka)
InvalidSessionTimeout (Kafka)
InvalidStateError (Kafka::TransactionStateMachine)
InvalidTimestamp (Kafka)
InvalidTopic (Kafka)
InvalidTransactionTimeoutError (Kafka)
InvalidTransitionError (Kafka::TransactionStateMachine)
InvalidTxnStateError (Kafka)

J

JoinGroupRequest (Kafka::Protocol)
JoinGroupResponse (Kafka::Protocol)

K

Kafka

L

LZ4Codec (Kafka)
LeaderNotAvailable (Kafka)
LeaveGroupRequest (Kafka::Protocol)
LeaveGroupResponse (Kafka::Protocol)
ListGroupsRequest (Kafka::Protocol)
ListGroupsResponse (Kafka::Protocol)
ListOffsetRequest (Kafka::Protocol)
ListOffsetResponse (Kafka::Protocol)

M

Member (Kafka::Protocol::DescribeGroupsResponse)
MemberAssignment (Kafka::Protocol)
Message (Kafka::Protocol)
MessageBuffer (Kafka)
MessageSet (Kafka::Protocol)
MessageSizeTooLarge (Kafka)
MessageTooLargeToRead (Kafka)
Metadata (Kafka::Protocol::JoinGroupResponse)
MetadataRequest (Kafka::Protocol)
MetadataResponse (Kafka::Protocol)
Murmur2Hash (Kafka)

N

O

OAuth (Kafka::Sasl)
OffsetCommitError (Kafka)
OffsetCommitRequest (Kafka::Protocol)
OffsetCommitResponse (Kafka::Protocol)
OffsetFetchRequest (Kafka::Protocol)
OffsetFetchResponse (Kafka::Protocol)
OffsetManager (Kafka)
OffsetMetadataTooLarge (Kafka)
OffsetOutOfRange (Kafka)
OutOfOrderSequenceNumberError (Kafka)

P

Partition (Kafka::ConsumerGroup::Assignor)
PartitionError (Kafka::Protocol::TxnOffsetCommitResponse)
PartitionError (Kafka::Protocol::AddPartitionsToTxnResponse)
PartitionInfo (Kafka::Protocol::ProduceResponse)
PartitionMetadata (Kafka::Protocol::MetadataResponse)
PartitionOffsetInfo (Kafka::Protocol::OffsetFetchResponse)
PartitionOffsetInfo (Kafka::Protocol::ListOffsetResponse)
Partitioner (Kafka)
Pause (Kafka)
PendingMessage (Kafka)
PendingMessageQueue (Kafka)
Plain (Kafka::Sasl)
PolicyViolation (Kafka)
ProcessingError (Kafka)
ProduceOperation (Kafka)
ProduceRequest (Kafka::Protocol)
ProduceResponse (Kafka::Protocol)
Producer (Kafka)
ProducerSubscriber (Kafka::Prometheus)
ProducerSubscriber (Kafka::Datadog)
ProducerSubscriber (Kafka::Statsd)
Prometheus (Kafka)
Protocol (Kafka)
ProtocolError (Kafka)

R

RebalanceInProgress (Kafka)
Record (Kafka::Protocol)
RecordBatch (Kafka::Protocol)
RecordListTooLarge (Kafka)
ReplicaNotAvailable (Kafka)
RequestMessage (Kafka::Protocol)
RequestTimedOut (Kafka)
ResourceDescription (Kafka::Protocol::DescribeConfigsResponse)
ResourceDescription (Kafka::Protocol::AlterConfigsResponse)
RoundRobinAssignmentStrategy (Kafka)

S

SSLSocketWithTimeout (Kafka)
Sasl (Kafka)
SaslAuthenticator (Kafka)
SaslHandshakeRequest (Kafka::Protocol)
SaslHandshakeResponse (Kafka::Protocol)
SaslScramError (Kafka)
Scram (Kafka::Sasl)
SnappyCodec (Kafka)
SocketWithTimeout (Kafka)
SslContext (Kafka)
StaleControllerEpoch (Kafka)
Statsd (Kafka)
StatsdSubscriber (Kafka::Datadog)
StatsdSubscriber (Kafka::Statsd)
SyncGroupRequest (Kafka::Protocol)
SyncGroupResponse (Kafka::Protocol)

T

TaggedLogger (Kafka)
Timer (Kafka::AsyncProducer)
TokenMethodNotImplementedError (Kafka)
TopicAlreadyExists (Kafka)
TopicAuthorizationFailed (Kafka)
TopicInfo (Kafka::Protocol::ProduceResponse)
TopicMetadata (Kafka::Protocol::MetadataResponse)
TopicOffsetInfo (Kafka::Protocol::ListOffsetResponse)
TopicPartitionsError (Kafka::Protocol::AddPartitionsToTxnResponse)
TopicPartitionsError (Kafka::Protocol::TxnOffsetCommitResponse)
TransactionCoordinatorFencedError (Kafka)
TransactionManager (Kafka)
TransactionStateMachine (Kafka)
TxnOffsetCommitRequest (Kafka::Protocol)
TxnOffsetCommitResponse (Kafka::Protocol)

U

W

Worker (Kafka::AsyncProducer)

Z

ZstdCodec (Kafka)