Documentation for ruby-kafka-custom (0.7.7.26)

Alphabetic Index

Namespace Listing A-Z

A

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

B

Broker (Kafka)
BrokerInfo (Kafka)
BrokerPool (Kafka)
BrokerUri (Kafka)

C

Client (Kafka)
Cluster (Kafka)
Compression (Kafka)
Compressor (Kafka)
ConfigEntry (Kafka::Protocol::DescribeConfigsResponse)
Connection (Kafka)
ConnectionBuilder (Kafka)
ConnectionSubscriber (Kafka::Datadog)
ConnectionSubscriber (Kafka::Statsd)
Consumer (Kafka)
ConsumerGroup (Kafka)
ConsumerGroupProtocol (Kafka::Protocol)
ConsumerSubscriber (Kafka::Datadog)
ConsumerSubscriber (Kafka::Statsd)
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)
DescribeConfigsRequest (Kafka::Protocol)
DescribeConfigsResponse (Kafka::Protocol)
DescribeGroupsRequest (Kafka::Protocol)
DescribeGroupsResponse (Kafka::Protocol)

E

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

F

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)
FindCoordinatorRequest (Kafka::Protocol)
FindCoordinatorResponse (Kafka::Protocol)

G

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

H

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

I

InitProducerIDRequest (Kafka::Protocol)
InitProducerIDResponse (Kafka::Protocol)
Instrumenter (Kafka)
InvalidStateError (Kafka::TransactionStateMachine)
InvalidTransitionError (Kafka::TransactionStateMachine)

J

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

K

Kafka

L

LZ4Codec (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)
MetadataRequest (Kafka::Protocol)
MetadataResponse (Kafka::Protocol)

O

OAuth (Kafka::Sasl)
OffsetCommitRequest (Kafka::Protocol)
OffsetCommitResponse (Kafka::Protocol)
OffsetFetchRequest (Kafka::Protocol)
OffsetFetchResponse (Kafka::Protocol)
OffsetManager (Kafka)

P

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)
ProduceOperation (Kafka)
ProduceRequest (Kafka::Protocol)
ProduceResponse (Kafka::Protocol)
Producer (Kafka)
ProducerSubscriber (Kafka::Datadog)
ProducerSubscriber (Kafka::Statsd)
Protocol (Kafka)

R

Record (Kafka::Protocol)
RecordBatch (Kafka::Protocol)
RequestMessage (Kafka::Protocol)
ResourceDescription (Kafka::Protocol::AlterConfigsResponse)
ResourceDescription (Kafka::Protocol::DescribeConfigsResponse)
RoundRobinAssignmentStrategy (Kafka)

S

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

T

TaggedFormatter (Kafka)
TaggedLogger (Kafka)
Timer (Kafka::AsyncProducer)
TopicInfo (Kafka::Protocol::ProduceResponse)
TopicMetadata (Kafka::Protocol::MetadataResponse)
TopicOffsetInfo (Kafka::Protocol::ListOffsetResponse)
TopicPartitionsError (Kafka::Protocol::AddPartitionsToTxnResponse)
TransactionManager (Kafka)
TransactionStateMachine (Kafka)

W

Worker (Kafka::AsyncProducer)