Libraries
»
ruby-kafka-custom
(0.7.7.26)
»
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)