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::BrokerInfo
class Kafka::BrokerNotAvailable
class Kafka::BrokerPool
class Kafka::BufferOverflow
class Kafka::Client
class Kafka::Cluster
class Kafka::ClusterAuthorizationFailed
class Kafka::Compressor
class Kafka::ConcurrentTransactionError
class Kafka::Connection
class Kafka::ConnectionBuilder
class Kafka::ConnectionError
class Kafka::Consumer
class Kafka::ConsumerGroup
class Kafka::CoordinatorLoadInProgress
class Kafka::CoordinatorNotAvailable
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::DuplicateSequenceNumberError
class Kafka::Error
class Kafka::FailedScramAuthentication
class Kafka::FetchError
class Kafka::FetchOperation
class Kafka::FetchedBatch
class Kafka::FetchedBatchGenerator
class Kafka::FetchedMessage
class Kafka::FetchedOffsetResolver
class Kafka::Fetcher
class Kafka::GroupAuthorizationFailed
class Kafka::GzipCodec
class Kafka::Heartbeat
class Kafka::HeartbeatError
class Kafka::IdleConnection
class Kafka::IllegalGeneration
class Kafka::InconsistentGroupProtocol
class Kafka::Instrumenter
class Kafka::InsufficientDataMessage
class Kafka::InvalidCommitOffsetSize
class Kafka::InvalidConfig
class Kafka::InvalidGroupId
class Kafka::InvalidMessageSize
class Kafka::InvalidPartitions
class Kafka::InvalidProducerEpochError
class Kafka::InvalidProducerIDMappingError
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::InvalidTransactionTimeoutError
class Kafka::InvalidTxnStateError
class Kafka::LZ4Codec
class Kafka::LeaderNotAvailable
class Kafka::MessageBuffer
class Kafka::MessageSizeTooLarge
class Kafka::MessageTooLargeToRead
class Kafka::NetworkException
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::OutOfOrderSequenceNumberError
class Kafka::Partitioner
class Kafka::Pause
class Kafka::PendingMessage
class Kafka::PendingMessageQueue
class Kafka::PolicyViolation
class Kafka::ProcessingError
class Kafka::ProduceOperation
class Kafka::Producer
class Kafka::Producer::AbortTransaction
class Kafka::Protocol::AddPartitionsToTxnRequest
class Kafka::Protocol::AddPartitionsToTxnResponse
class Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
class Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
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::DescribeGroupsRequest
class Kafka::Protocol::DescribeGroupsResponse
class Kafka::Protocol::DescribeGroupsResponse::Group
class Kafka::Protocol::DescribeGroupsResponse::Member
class Kafka::Protocol::Encoder
class Kafka::Protocol::EndTxnRequest
class Kafka::Protocol::EndTxnResposne
class Kafka::Protocol::FetchRequest
class Kafka::Protocol::FetchResponse
class Kafka::Protocol::FetchResponse::AbortedTransaction
class Kafka::Protocol::FetchResponse::FetchedPartition
class Kafka::Protocol::FetchResponse::FetchedTopic
class Kafka::Protocol::FindCoordinatorRequest
class Kafka::Protocol::FindCoordinatorResponse
class Kafka::Protocol::HeartbeatRequest
class Kafka::Protocol::HeartbeatResponse
class Kafka::Protocol::InitProducerIDRequest
class Kafka::Protocol::InitProducerIDResponse
class Kafka::Protocol::JoinGroupRequest
class Kafka::Protocol::JoinGroupResponse
class Kafka::Protocol::LeaveGroupRequest
class Kafka::Protocol::LeaveGroupResponse
class Kafka::Protocol::ListGroupsRequest
class Kafka::Protocol::ListGroupsResponse
class Kafka::Protocol::ListGroupsResponse::GroupEntry
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::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::Record
class Kafka::Protocol::RecordBatch
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::StaleControllerEpoch
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::TransactionCoordinatorFencedError
class Kafka::TransactionManager
class Kafka::TransactionStateMachine
class Kafka::TransactionStateMachine::InvalidStateError
class Kafka::TransactionStateMachine::InvalidTransitionError
class Kafka::UnknownError
class Kafka::UnknownMemberId
class Kafka::UnknownTopicOrPartition
class Kafka::UnsupportedForMessageFormat
class Kafka::UnsupportedSaslMechanism
class Kafka::UnsupportedVersion
ruby-kafka
0.7.4
segment size.If a message batch in a produce request exceeds the maximum configured18