Home
Pages
Classes
Methods
Class and Module Index
Kafka
Kafka::AsyncProducer
Kafka::AsyncProducer::Timer
Kafka::AsyncProducer::Worker
Kafka::Broker
Kafka::BrokerInfo
Kafka::BrokerNotAvailable
Kafka::BrokerPool
Kafka::BrokerUri
Kafka::BufferOverflow
Kafka::Client
Kafka::Cluster
Kafka::ClusterAuthorizationFailed
Kafka::Compression
Kafka::Compressor
Kafka::ConcurrentTransactionError
Kafka::Connection
Kafka::ConnectionBuilder
Kafka::ConnectionError
Kafka::Consumer
Kafka::ConsumerGroup
Kafka::ConsumerGroup::Assignor
Kafka::CoordinatorLoadInProgress
Kafka::CoordinatorNotAvailable
Kafka::CorruptMessage
Kafka::Crc32Hash
Kafka::Datadog
Kafka::Datadog::AsyncProducerSubscriber
Kafka::Datadog::ConnectionSubscriber
Kafka::Datadog::ConsumerSubscriber
Kafka::Datadog::FetcherSubscriber
Kafka::Datadog::ProducerSubscriber
Kafka::Datadog::StatsdSubscriber
Kafka::DecoratingInstrumenter
Kafka::DeliveryFailed
Kafka::Digest
Kafka::DuplicateSequenceNumberError
Kafka::Error
Kafka::FailedScramAuthentication
Kafka::FetchError
Kafka::FetchOperation
Kafka::FetchedBatch
Kafka::FetchedBatchGenerator
Kafka::FetchedMessage
Kafka::FetchedOffsetResolver
Kafka::Fetcher
Kafka::GroupAuthorizationFailed
Kafka::GzipCodec
Kafka::Heartbeat
Kafka::HeartbeatError
Kafka::IdleConnection
Kafka::IllegalGeneration
Kafka::InconsistentGroupProtocol
Kafka::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::InvalidTimestamp
Kafka::InvalidTopic
Kafka::InvalidTransactionTimeoutError
Kafka::InvalidTxnStateError
Kafka::LZ4Codec
Kafka::LeaderNotAvailable
Kafka::MessageBuffer
Kafka::MessageSizeTooLarge
Kafka::MessageTooLargeToRead
Kafka::Murmur2Hash
Kafka::NetworkException
Kafka::NoPartitionsToFetchFrom
Kafka::NoSuchBroker
Kafka::NotController
Kafka::NotCoordinatorForGroup
Kafka::NotEnoughReplicas
Kafka::NotEnoughReplicasAfterAppend
Kafka::NotLeaderForPartition
Kafka::OffsetCommitError
Kafka::OffsetManager
Kafka::OffsetMetadataTooLarge
Kafka::OffsetOutOfRange
Kafka::OutOfOrderSequenceNumberError
Kafka::Partitioner
Kafka::Pause
Kafka::PendingMessage
Kafka::PendingMessageQueue
Kafka::PolicyViolation
Kafka::ProcessingError
Kafka::ProduceOperation
Kafka::Producer
Kafka::Producer::AbortTransaction
Kafka::Prometheus
Kafka::Prometheus::AsyncProducerSubscriber
Kafka::Prometheus::ConnectionSubscriber
Kafka::Prometheus::ConsumerSubscriber
Kafka::Prometheus::FetcherSubscriber
Kafka::Prometheus::ProducerSubscriber
Kafka::Protocol
Kafka::Protocol::AddOffsetsToTxnRequest
Kafka::Protocol::AddOffsetsToTxnResponse
Kafka::Protocol::AddPartitionsToTxnRequest
Kafka::Protocol::AddPartitionsToTxnResponse
Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
Kafka::Protocol::AlterConfigsRequest
Kafka::Protocol::AlterConfigsResponse
Kafka::Protocol::AlterConfigsResponse::ResourceDescription
Kafka::Protocol::ApiVersionsRequest
Kafka::Protocol::ApiVersionsResponse
Kafka::Protocol::ApiVersionsResponse::ApiInfo
Kafka::Protocol::ConsumerGroupProtocol
Kafka::Protocol::CreatePartitionsRequest
Kafka::Protocol::CreatePartitionsResponse
Kafka::Protocol::CreateTopicsRequest
Kafka::Protocol::CreateTopicsResponse
Kafka::Protocol::Decoder
Kafka::Protocol::DeleteTopicsRequest
Kafka::Protocol::DeleteTopicsResponse
Kafka::Protocol::DescribeConfigsRequest
Kafka::Protocol::DescribeConfigsResponse
Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
Kafka::Protocol::DescribeGroupsRequest
Kafka::Protocol::DescribeGroupsResponse
Kafka::Protocol::DescribeGroupsResponse::Group
Kafka::Protocol::DescribeGroupsResponse::Member
Kafka::Protocol::Encoder
Kafka::Protocol::EndTxnRequest
Kafka::Protocol::EndTxnResposne
Kafka::Protocol::FetchRequest
Kafka::Protocol::FetchResponse
Kafka::Protocol::FetchResponse::AbortedTransaction
Kafka::Protocol::FetchResponse::FetchedPartition
Kafka::Protocol::FetchResponse::FetchedTopic
Kafka::Protocol::FindCoordinatorRequest
Kafka::Protocol::FindCoordinatorResponse
Kafka::Protocol::HeartbeatRequest
Kafka::Protocol::HeartbeatResponse
Kafka::Protocol::InitProducerIDRequest
Kafka::Protocol::InitProducerIDResponse
Kafka::Protocol::JoinGroupRequest
Kafka::Protocol::JoinGroupResponse
Kafka::Protocol::LeaveGroupRequest
Kafka::Protocol::LeaveGroupResponse
Kafka::Protocol::ListGroupsRequest
Kafka::Protocol::ListGroupsResponse
Kafka::Protocol::ListGroupsResponse::GroupEntry
Kafka::Protocol::ListOffsetRequest
Kafka::Protocol::ListOffsetResponse
Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
Kafka::Protocol::MemberAssignment
Kafka::Protocol::Message
Kafka::Protocol::MessageSet
Kafka::Protocol::MetadataRequest
Kafka::Protocol::MetadataResponse
Kafka::Protocol::MetadataResponse::PartitionMetadata
Kafka::Protocol::MetadataResponse::TopicMetadata
Kafka::Protocol::OffsetCommitRequest
Kafka::Protocol::OffsetCommitResponse
Kafka::Protocol::OffsetFetchRequest
Kafka::Protocol::OffsetFetchResponse
Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
Kafka::Protocol::ProduceRequest
Kafka::Protocol::ProduceResponse
Kafka::Protocol::ProduceResponse::PartitionInfo
Kafka::Protocol::ProduceResponse::TopicInfo
Kafka::Protocol::Record
Kafka::Protocol::RecordBatch
Kafka::Protocol::RequestMessage
Kafka::Protocol::SaslHandshakeRequest
Kafka::Protocol::SaslHandshakeResponse
Kafka::Protocol::SyncGroupRequest
Kafka::Protocol::SyncGroupResponse
Kafka::Protocol::TxnOffsetCommitRequest
Kafka::Protocol::TxnOffsetCommitResponse
Kafka::Protocol::TxnOffsetCommitResponse::PartitionError
Kafka::Protocol::TxnOffsetCommitResponse::TopicPartitionsError
Kafka::ProtocolError
Kafka::RebalanceInProgress
Kafka::RecordListTooLarge
Kafka::ReplicaNotAvailable
Kafka::RequestTimedOut
Kafka::RoundRobinAssignmentStrategy
Kafka::SSLSocketWithTimeout
Kafka::Sasl
Kafka::Sasl::Gssapi
Kafka::Sasl::OAuth
Kafka::Sasl::Plain
Kafka::Sasl::Scram
Kafka::SaslAuthenticator
Kafka::SaslScramError
Kafka::SnappyCodec
Kafka::SocketWithTimeout
Kafka::SslContext
Kafka::StaleControllerEpoch
Kafka::Statsd
Kafka::Statsd::AsyncProducerSubscriber
Kafka::Statsd::ConnectionSubscriber
Kafka::Statsd::ConsumerSubscriber
Kafka::Statsd::FetcherSubscriber
Kafka::Statsd::ProducerSubscriber
Kafka::Statsd::StatsdSubscriber
Kafka::TaggedLogger
Kafka::TokenMethodNotImplementedError
Kafka::TopicAlreadyExists
Kafka::TopicAuthorizationFailed
Kafka::TransactionCoordinatorFencedError
Kafka::TransactionManager
Kafka::TransactionStateMachine
Kafka::TransactionStateMachine::InvalidStateError
Kafka::TransactionStateMachine::InvalidTransitionError
Kafka::UnknownError
Kafka::UnknownMemberId
Kafka::UnknownTopicOrPartition
Kafka::UnsupportedForMessageFormat
Kafka::UnsupportedSaslMechanism
Kafka::UnsupportedVersion
Kafka::ZstdCodec
This is the API documentation for ruby-kafka-temp-fork-0.0.2 Documentation.