Featured Classes

Demo

DescribeConfigsRequest

class

Kafka::Protocol

Cluster

class

Kafka

ProtocolError

class

Kafka

ConsumerSubscriber

class

Kafka::Statsd

Producer

class

Kafka

LZ4Codec

class

Kafka

All Classes

AsyncProducer

class

Kafka

Timer

class

Kafka::AsyncProducer

Worker

class

Kafka::AsyncProducer

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

AsyncProducerSubscriber

class

Kafka::Datadog

ConnectionSubscriber

class

Kafka::Datadog

ConsumerSubscriber

class

Kafka::Datadog

FetcherSubscriber

class

Kafka::Datadog

ProducerSubscriber

class

Kafka::Datadog

StatsdSubscriber

class

Kafka::Datadog

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

AlterConfigsRequest

class

Kafka::Protocol

AlterConfigsResponse

class

Kafka::Protocol

ResourceDescription

class

Kafka::Protocol::AlterConfigsResponse

ApiVersionsRequest

class

Kafka::Protocol

ApiVersionsResponse

class

Kafka::Protocol

ApiInfo

class

Kafka::Protocol::ApiVersionsResponse

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

ConfigEntry

class

Kafka::Protocol::DescribeConfigsResponse

ResourceDescription

class

Kafka::Protocol::DescribeConfigsResponse

Encoder

class

Kafka::Protocol

FetchRequest

class

Kafka::Protocol

FetchResponse

class

Kafka::Protocol

FetchedPartition

class

Kafka::Protocol::FetchResponse

FetchedTopic

class

Kafka::Protocol::FetchResponse

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

PartitionOffsetInfo

class

Kafka::Protocol::ListOffsetResponse

TopicOffsetInfo

class

Kafka::Protocol::ListOffsetResponse

MemberAssignment

class

Kafka::Protocol

Message

class

Kafka::Protocol

MessageSet

class

Kafka::Protocol

MetadataRequest

class

Kafka::Protocol

MetadataResponse

class

Kafka::Protocol

BrokerInfo

class

Kafka::Protocol::MetadataResponse

PartitionMetadata

class

Kafka::Protocol::MetadataResponse

TopicMetadata

class

Kafka::Protocol::MetadataResponse

OffsetCommitRequest

class

Kafka::Protocol

OffsetCommitResponse

class

Kafka::Protocol

OffsetFetchRequest

class

Kafka::Protocol

OffsetFetchResponse

class

Kafka::Protocol

PartitionOffsetInfo

class

Kafka::Protocol::OffsetFetchResponse

ProduceRequest

class

Kafka::Protocol

ProduceResponse

class

Kafka::Protocol

PartitionInfo

class

Kafka::Protocol::ProduceResponse

TopicInfo

class

Kafka::Protocol::ProduceResponse

RequestMessage

class

Kafka::Protocol

SaslHandshakeRequest

class

Kafka::Protocol

SaslHandshakeResponse

class

Kafka::Protocol

SyncGroupRequest

class

Kafka::Protocol

SyncGroupResponse

class

Kafka::Protocol

ProtocolError

class

Kafka

RebalanceInProgress

class

Kafka

RecordListTooLarge

class

Kafka

ReplicaNotAvailable

class

Kafka

RequestTimedOut

class

Kafka

RoundRobinAssignmentStrategy

class

Kafka

SSLSocketWithTimeout

class

Kafka

Gssapi

class

Kafka::Sasl

Plain

class

Kafka::Sasl

Scram

class

Kafka::Sasl

SaslAuthenticator

class

Kafka

SaslScramError

class

Kafka

SnappyCodec

class

Kafka

SocketWithTimeout

class

Kafka

AsyncProducerSubscriber

class

Kafka::Statsd

ConnectionSubscriber

class

Kafka::Statsd

ConsumerSubscriber

class

Kafka::Statsd

FetcherSubscriber

class

Kafka::Statsd

ProducerSubscriber

class

Kafka::Statsd

StatsdSubscriber

class

Kafka::Statsd

TopicAlreadyExists

class

Kafka

TopicAuthorizationFailed

class

Kafka

UnknownError

class

Kafka

UnknownMemberId

class

Kafka

UnknownTopicOrPartition

class

Kafka

UnsupportedSaslMechanism

class

Kafka

UnsupportedVersion

class

Kafka

All Modules

Kafka

module

BrokerUri

module

Kafka

Compression

module

Kafka

Datadog

module

Kafka

Protocol

module

Kafka

Sasl

module

Kafka

SslContext

module

Kafka

Statsd

module

Kafka