Class List

Classes Methods Files

Search:

Top Level Namespace
KafkaTop Level Namespace
- AsyncProducer < ObjectKafka
  - Timer < ObjectKafka::AsyncProducer
  - Worker < ObjectKafka::AsyncProducer
- Broker < ObjectKafka
- BrokerInfo < ObjectKafka
- BrokerNotAvailable < ProtocolErrorKafka
- BrokerPool < ObjectKafka
- BrokerUriKafka
- BufferOverflow < ErrorKafka
- Client < ObjectKafka
- Cluster < ObjectKafka
- ClusterAuthorizationFailed < ProtocolErrorKafka
- CompressionKafka
- Compressor < ObjectKafka
- ConcurrentTransactionError < ErrorKafka
- Connection < ObjectKafka
- ConnectionBuilder < ObjectKafka
- ConnectionError < ErrorKafka
- Consumer < ObjectKafka
- ConsumerGroup < ObjectKafka
  - Assignor < ObjectKafka::ConsumerGroup
    Partition < StructKafka::ConsumerGroup::Assignor
- CoordinatorLoadInProgress < ProtocolErrorKafka
- CoordinatorNotAvailable < ProtocolErrorKafka
- CorruptMessage < ProtocolErrorKafka
- Crc32Hash < ObjectKafka
- DatadogKafka
  - AsyncProducerSubscriber < StatsdSubscriberKafka::Datadog
  - ConnectionSubscriber < StatsdSubscriberKafka::Datadog
  - ConsumerSubscriber < StatsdSubscriberKafka::Datadog
  - FetcherSubscriber < StatsdSubscriberKafka::Datadog
  - ProducerSubscriber < StatsdSubscriberKafka::Datadog
  - StatsdSubscriber < SubscriberKafka::Datadog
- DecoratingInstrumenter < ObjectKafka
- DeliveryFailed < ErrorKafka
- DigestKafka
- DuplicateSequenceNumberError < ErrorKafka
- Error < StandardErrorKafka
- FailedScramAuthentication < SaslScramErrorKafka
- FetchError < ErrorKafka
- FetchOperation < ObjectKafka
- FetchedBatch < ObjectKafka
- FetchedBatchGenerator < ObjectKafka
- FetchedMessage < ObjectKafka
- FetchedOffsetResolver < ObjectKafka
- Fetcher < ObjectKafka
- GroupAuthorizationFailed < ProtocolErrorKafka
- GzipCodec < ObjectKafka
- Heartbeat < ObjectKafka
- HeartbeatError < ErrorKafka
- IdleConnection < ErrorKafka
- IllegalGeneration < ProtocolErrorKafka
- InconsistentGroupProtocol < ProtocolErrorKafka
- Instrumenter < ObjectKafka
- InsufficientDataMessage < ErrorKafka
- Interceptors < ObjectKafka
- InvalidCommitOffsetSize < ProtocolErrorKafka
- InvalidConfig < ProtocolErrorKafka
- InvalidGroupId < ProtocolErrorKafka
- InvalidMessageSize < ProtocolErrorKafka
- InvalidPartitions < ProtocolErrorKafka
- InvalidProducerEpochError < ErrorKafka
- InvalidProducerIDMappingError < ErrorKafka
- InvalidReplicaAssignment < ProtocolErrorKafka
- InvalidReplicationFactor < ProtocolErrorKafka
- InvalidRequest < ProtocolErrorKafka
- InvalidRequiredAcks < ProtocolErrorKafka
- InvalidSaslState < ProtocolErrorKafka
- InvalidSessionTimeout < ProtocolErrorKafka
- InvalidTimestamp < ProtocolErrorKafka
- InvalidTopic < ProtocolErrorKafka
- InvalidTransactionTimeoutError < ErrorKafka
- InvalidTxnStateError < ErrorKafka
- LZ4Codec < ObjectKafka
- LeaderNotAvailable < ProtocolErrorKafka
- MessageBuffer < ObjectKafka
- MessageSizeTooLarge < ProtocolErrorKafka
- MessageTooLargeToRead < ErrorKafka
- Murmur2Hash < ObjectKafka
- NetworkException < ProtocolErrorKafka
- NoPartitionsToFetchFrom < ErrorKafka
- NoSuchBroker < ErrorKafka
- NotController < ProtocolErrorKafka
- NotCoordinatorForGroup < ProtocolErrorKafka
- NotEnoughReplicas < ProtocolErrorKafka
- NotEnoughReplicasAfterAppend < ProtocolErrorKafka
- NotLeaderForPartition < ProtocolErrorKafka
- OffsetCommitError < ErrorKafka
- OffsetManager < ObjectKafka
- OffsetMetadataTooLarge < ProtocolErrorKafka
- OffsetOutOfRange < ProtocolErrorKafka
- OutOfOrderSequenceNumberError < ErrorKafka
- Partitioner < ObjectKafka
- Pause < ObjectKafka
- PendingMessage < ObjectKafka
- PendingMessageQueue < ObjectKafka
- PolicyViolation < ProtocolErrorKafka
- ProcessingError < ErrorKafka
- ProduceOperation < ObjectKafka
- Producer < ObjectKafka
  - AbortTransaction < StandardErrorKafka::Producer
- PrometheusKafka
  - AsyncProducerSubscriber < SubscriberKafka::Prometheus
  - ConnectionSubscriber < SubscriberKafka::Prometheus
  - ConsumerSubscriber < SubscriberKafka::Prometheus
  - FetcherSubscriber < SubscriberKafka::Prometheus
  - ProducerSubscriber < SubscriberKafka::Prometheus
- ProtocolKafka
  - AddOffsetsToTxnRequest < ObjectKafka::Protocol
  - AddOffsetsToTxnResponse < ObjectKafka::Protocol
  - AddPartitionsToTxnRequest < ObjectKafka::Protocol
  - AddPartitionsToTxnResponse < ObjectKafka::Protocol
    PartitionError < ObjectKafka::Protocol::AddPartitionsToTxnResponse
    TopicPartitionsError < ObjectKafka::Protocol::AddPartitionsToTxnResponse
  - AlterConfigsRequest < ObjectKafka::Protocol
  - AlterConfigsResponse < ObjectKafka::Protocol
    ResourceDescription < ObjectKafka::Protocol::AlterConfigsResponse
  - ApiVersionsRequest < ObjectKafka::Protocol
  - ApiVersionsResponse < ObjectKafka::Protocol
    ApiInfo < ObjectKafka::Protocol::ApiVersionsResponse
  - ConsumerGroupProtocol < ObjectKafka::Protocol
  - CreatePartitionsRequest < ObjectKafka::Protocol
  - CreatePartitionsResponse < ObjectKafka::Protocol
  - CreateTopicsRequest < ObjectKafka::Protocol
  - CreateTopicsResponse < ObjectKafka::Protocol
  - Decoder < ObjectKafka::Protocol
  - DeleteTopicsRequest < ObjectKafka::Protocol
  - DeleteTopicsResponse < ObjectKafka::Protocol
  - DescribeConfigsRequest < ObjectKafka::Protocol
  - DescribeConfigsResponse < ObjectKafka::Protocol
    ConfigEntry < ObjectKafka::Protocol::DescribeConfigsResponse
    ResourceDescription < ObjectKafka::Protocol::DescribeConfigsResponse
  - DescribeGroupsRequest < ObjectKafka::Protocol
  - DescribeGroupsResponse < ObjectKafka::Protocol
    Group < ObjectKafka::Protocol::DescribeGroupsResponse
    Member < ObjectKafka::Protocol::DescribeGroupsResponse
  - Encoder < ObjectKafka::Protocol
  - EndTxnRequest < ObjectKafka::Protocol
  - EndTxnResposne < ObjectKafka::Protocol
  - FetchRequest < ObjectKafka::Protocol
  - FetchResponse < ObjectKafka::Protocol
    AbortedTransaction < ObjectKafka::Protocol::FetchResponse
    FetchedPartition < ObjectKafka::Protocol::FetchResponse
    FetchedTopic < ObjectKafka::Protocol::FetchResponse
  - FindCoordinatorRequest < ObjectKafka::Protocol
  - FindCoordinatorResponse < ObjectKafka::Protocol
  - HeartbeatRequest < ObjectKafka::Protocol
  - HeartbeatResponse < ObjectKafka::Protocol
  - InitProducerIDRequest < ObjectKafka::Protocol
  - InitProducerIDResponse < ObjectKafka::Protocol
  - JoinGroupRequest < ObjectKafka::Protocol
  - JoinGroupResponse < ObjectKafka::Protocol
    Metadata < StructKafka::Protocol::JoinGroupResponse
  - LeaveGroupRequest < ObjectKafka::Protocol
  - LeaveGroupResponse < ObjectKafka::Protocol
  - ListGroupsRequest < ObjectKafka::Protocol
  - ListGroupsResponse < ObjectKafka::Protocol
    GroupEntry < ObjectKafka::Protocol::ListGroupsResponse
  - ListOffsetRequest < ObjectKafka::Protocol
  - ListOffsetResponse < ObjectKafka::Protocol
    PartitionOffsetInfo < ObjectKafka::Protocol::ListOffsetResponse
    TopicOffsetInfo < ObjectKafka::Protocol::ListOffsetResponse
  - MemberAssignment < ObjectKafka::Protocol
  - Message < ObjectKafka::Protocol
  - MessageSet < ObjectKafka::Protocol
  - MetadataRequest < ObjectKafka::Protocol
  - MetadataResponse < ObjectKafka::Protocol
    PartitionMetadata < ObjectKafka::Protocol::MetadataResponse
    TopicMetadata < ObjectKafka::Protocol::MetadataResponse
  - OffsetCommitRequest < ObjectKafka::Protocol
  - OffsetCommitResponse < ObjectKafka::Protocol
  - OffsetFetchRequest < ObjectKafka::Protocol
  - OffsetFetchResponse < ObjectKafka::Protocol
    PartitionOffsetInfo < ObjectKafka::Protocol::OffsetFetchResponse
  - ProduceRequest < ObjectKafka::Protocol
  - ProduceResponse < ObjectKafka::Protocol
    PartitionInfo < ObjectKafka::Protocol::ProduceResponse
    TopicInfo < ObjectKafka::Protocol::ProduceResponse
  - Record < ObjectKafka::Protocol
  - RecordBatch < ObjectKafka::Protocol
  - RequestMessage < ObjectKafka::Protocol
  - SaslHandshakeRequest < ObjectKafka::Protocol
  - SaslHandshakeResponse < ObjectKafka::Protocol
  - SyncGroupRequest < ObjectKafka::Protocol
  - SyncGroupResponse < ObjectKafka::Protocol
  - TxnOffsetCommitRequest < ObjectKafka::Protocol
  - TxnOffsetCommitResponse < ObjectKafka::Protocol
    PartitionError < ObjectKafka::Protocol::TxnOffsetCommitResponse
    TopicPartitionsError < ObjectKafka::Protocol::TxnOffsetCommitResponse
- ProtocolError < ErrorKafka
- RebalanceInProgress < ProtocolErrorKafka
- RecordListTooLarge < ProtocolErrorKafka
- ReplicaNotAvailable < ProtocolErrorKafka
- RequestTimedOut < ProtocolErrorKafka
- RoundRobinAssignmentStrategy < ObjectKafka
- SSLSocketWithTimeout < ObjectKafka
- SaslKafka
  - AwsMskIam < ObjectKafka::Sasl
  - Gssapi < ObjectKafka::Sasl
  - OAuth < ObjectKafka::Sasl
  - Plain < ObjectKafka::Sasl
  - Scram < ObjectKafka::Sasl
- SaslAuthenticator < ObjectKafka
- SaslScramError < ErrorKafka
- SnappyCodec < ObjectKafka
- SocketWithTimeout < ObjectKafka
- SslContextKafka
- StaleControllerEpoch < ProtocolErrorKafka
- StatsdKafka
  - AsyncProducerSubscriber < StatsdSubscriberKafka::Statsd
  - ConnectionSubscriber < StatsdSubscriberKafka::Statsd
  - ConsumerSubscriber < StatsdSubscriberKafka::Statsd
  - FetcherSubscriber < StatsdSubscriberKafka::Statsd
  - ProducerSubscriber < StatsdSubscriberKafka::Statsd
  - StatsdSubscriber < SubscriberKafka::Statsd
- TaggedLogger < SimpleDelegatorKafka
- TokenMethodNotImplementedError < ErrorKafka
- TopicAlreadyExists < ProtocolErrorKafka
- TopicAuthorizationFailed < ProtocolErrorKafka
- TransactionCoordinatorFencedError < ErrorKafka
- TransactionManager < ObjectKafka
- TransactionStateMachine < ObjectKafka
  - InvalidStateError < StandardErrorKafka::TransactionStateMachine
  - InvalidTransitionError < StandardErrorKafka::TransactionStateMachine
- UnknownError < ProtocolErrorKafka
- UnknownMemberId < ProtocolErrorKafka
- UnknownTopicOrPartition < ProtocolErrorKafka
- UnsupportedForMessageFormat < ProtocolErrorKafka
- UnsupportedSaslMechanism < ProtocolErrorKafka
- UnsupportedVersion < ProtocolErrorKafka
- ZstdCodec < ObjectKafka