module Kafka
module Kafka::BrokerUri
module Kafka::Compression
module Kafka::Datadog
module Kafka::Protocol
module Kafka::Sasl
module Kafka::SslContext
module Kafka::Statsd
class Kafka::AsyncProducer
class Kafka::AsyncProducer::Timer
class Kafka::AsyncProducer::Worker
class Kafka::Broker
class Kafka::BrokerNotAvailable
class Kafka::BrokerPool
class Kafka::BufferOverflow
class Kafka::Client
class Kafka::Cluster
class Kafka::ClusterAuthorizationFailed
class Kafka::Compressor
class Kafka::Connection
class Kafka::ConnectionBuilder
class Kafka::ConnectionError
class Kafka::Consumer
class Kafka::ConsumerGroup
class Kafka::CorruptMessage
class Kafka::Datadog::AsyncProducerSubscriber
class Kafka::Datadog::ConnectionSubscriber
class Kafka::Datadog::ConsumerSubscriber
class Kafka::Datadog::FetcherSubscriber
class Kafka::Datadog::ProducerSubscriber
class Kafka::Datadog::StatsdSubscriber
class Kafka::DecoratingInstrumenter
class Kafka::DeliveryFailed
class Kafka::Error
class Kafka::FailedScramAuthentication
class Kafka::FetchError
class Kafka::FetchOperation
class Kafka::FetchedBatch
class Kafka::FetchedMessage
class Kafka::Fetcher
class Kafka::GroupAuthorizationFailed
class Kafka::GroupCoordinatorNotAvailable
class Kafka::GzipCodec
class Kafka::Heartbeat
class Kafka::HeartbeatError
class Kafka::IdleConnection
class Kafka::IllegalGeneration
class Kafka::Instrumenter
class Kafka::InvalidCommitOffsetSize
class Kafka::InvalidConfig
class Kafka::InvalidMessageSize
class Kafka::InvalidPartitions
class Kafka::InvalidReplicaAssignment
class Kafka::InvalidReplicationFactor
class Kafka::InvalidRequest
class Kafka::InvalidRequiredAcks
class Kafka::InvalidSaslState
class Kafka::InvalidSessionTimeout
class Kafka::InvalidTimestamp
class Kafka::InvalidTopic
class Kafka::LZ4Codec
class Kafka::LeaderNotAvailable
class Kafka::MessageBuffer
class Kafka::MessageSizeTooLarge
class Kafka::MessageTooLargeToRead
class Kafka::NoPartitionsToFetchFrom
class Kafka::NoSuchBroker
class Kafka::NotController
class Kafka::NotCoordinatorForGroup
class Kafka::NotEnoughReplicas
class Kafka::NotEnoughReplicasAfterAppend
class Kafka::NotLeaderForPartition
class Kafka::OffsetCommitError
class Kafka::OffsetManager
class Kafka::OffsetMetadataTooLarge
class Kafka::OffsetOutOfRange
class Kafka::Partitioner
class Kafka::Pause
class Kafka::PendingMessage
class Kafka::PendingMessageQueue
class Kafka::ProcessingError
class Kafka::ProduceOperation
class Kafka::Producer
class Kafka::Protocol::AlterConfigsRequest
class Kafka::Protocol::AlterConfigsResponse
class Kafka::Protocol::AlterConfigsResponse::ResourceDescription
class Kafka::Protocol::ApiVersionsRequest
class Kafka::Protocol::ApiVersionsResponse
class Kafka::Protocol::ApiVersionsResponse::ApiInfo
class Kafka::Protocol::ConsumerGroupProtocol
class Kafka::Protocol::CreatePartitionsRequest
class Kafka::Protocol::CreatePartitionsResponse
class Kafka::Protocol::CreateTopicsRequest
class Kafka::Protocol::CreateTopicsResponse
class Kafka::Protocol::Decoder
class Kafka::Protocol::DeleteTopicsRequest
class Kafka::Protocol::DeleteTopicsResponse
class Kafka::Protocol::DescribeConfigsRequest
class Kafka::Protocol::DescribeConfigsResponse
class Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
class Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
class Kafka::Protocol::Encoder
class Kafka::Protocol::FetchRequest
class Kafka::Protocol::FetchResponse
class Kafka::Protocol::FetchResponse::FetchedPartition
class Kafka::Protocol::FetchResponse::FetchedTopic
class Kafka::Protocol::GroupCoordinatorRequest
class Kafka::Protocol::GroupCoordinatorResponse
class Kafka::Protocol::HeartbeatRequest
class Kafka::Protocol::HeartbeatResponse
class Kafka::Protocol::JoinGroupRequest
class Kafka::Protocol::JoinGroupResponse
class Kafka::Protocol::LeaveGroupRequest
class Kafka::Protocol::LeaveGroupResponse
class Kafka::Protocol::ListOffsetRequest
class Kafka::Protocol::ListOffsetResponse
class Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
class Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
class Kafka::Protocol::MemberAssignment
class Kafka::Protocol::Message
class Kafka::Protocol::MessageSet
class Kafka::Protocol::MetadataRequest
class Kafka::Protocol::MetadataResponse
class Kafka::Protocol::MetadataResponse::BrokerInfo
class Kafka::Protocol::MetadataResponse::PartitionMetadata
class Kafka::Protocol::MetadataResponse::TopicMetadata
class Kafka::Protocol::OffsetCommitRequest
class Kafka::Protocol::OffsetCommitResponse
class Kafka::Protocol::OffsetFetchRequest
class Kafka::Protocol::OffsetFetchResponse
class Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
class Kafka::Protocol::ProduceRequest
class Kafka::Protocol::ProduceResponse
class Kafka::Protocol::ProduceResponse::PartitionInfo
class Kafka::Protocol::ProduceResponse::TopicInfo
class Kafka::Protocol::RequestMessage
class Kafka::Protocol::SaslHandshakeRequest
class Kafka::Protocol::SaslHandshakeResponse
class Kafka::Protocol::SyncGroupRequest
class Kafka::Protocol::SyncGroupResponse
class Kafka::ProtocolError
class Kafka::RebalanceInProgress
class Kafka::RecordListTooLarge
class Kafka::ReplicaNotAvailable
class Kafka::RequestTimedOut
class Kafka::RoundRobinAssignmentStrategy
class Kafka::SSLSocketWithTimeout
class Kafka::Sasl::Gssapi
class Kafka::Sasl::Plain
class Kafka::Sasl::Scram
class Kafka::SaslAuthenticator
class Kafka::SaslScramError
class Kafka::SnappyCodec
class Kafka::SocketWithTimeout
class Kafka::Statsd::AsyncProducerSubscriber
class Kafka::Statsd::ConnectionSubscriber
class Kafka::Statsd::ConsumerSubscriber
class Kafka::Statsd::FetcherSubscriber
class Kafka::Statsd::ProducerSubscriber
class Kafka::Statsd::StatsdSubscriber
class Kafka::TopicAlreadyExists
class Kafka::TopicAuthorizationFailed
class Kafka::UnknownError
class Kafka::UnknownMemberId
class Kafka::UnknownTopicOrPartition
class Kafka::UnsupportedSaslMechanism
class Kafka::UnsupportedVersion
ruby-kafka
0.6.0
# buffer_for
def buffer_for(topic, partition) @buffer[topic] ||= {} @buffer[topic][partition] ||= [] end