Method List

Classes Methods Files

Search:

#== Kafka::Protocol::MessageSet
#== Kafka::Protocol::RecordBatch
#== Kafka::Protocol::Record
#== Kafka::Protocol::Message
#== Kafka::PendingMessage
#abort_transaction Kafka::Producer
#abort_transaction Kafka::TransactionManager
#aborted_transactions Kafka::Protocol::FetchResponse::FetchedPartition
#aborting_transaction? Kafka::TransactionStateMachine
#ack_message Kafka::Datadog::ProducerSubscriber
#ack_message Kafka::Statsd::ProducerSubscriber
#ack_message Kafka::Prometheus::ProducerSubscriber
#add_offsets_to_txn Kafka::Broker
#add_partitions_to_transaction Kafka::TransactionManager
#add_partitions_to_txn Kafka::Broker
#add_target_topics Kafka::Cluster
#address_match? Kafka::Broker
#alter_configs Kafka::Broker
#alter_configs Kafka::Cluster
#alter_configs Kafka::Client
#alter_topic Kafka::Cluster
#alter_topic Kafka::Client
#api_info Kafka::Cluster
#api_key Kafka::Protocol::CreatePartitionsRequest
#api_key Kafka::Protocol::ListOffsetRequest
#api_key Kafka::Protocol::TxnOffsetCommitRequest
#api_key Kafka::Protocol::AddPartitionsToTxnRequest
#api_key Kafka::Protocol::FetchRequest
#api_key Kafka::Protocol::OffsetCommitRequest
#api_key Kafka::Protocol::EndTxnRequest
#api_key Kafka::Protocol::ApiVersionsRequest
#api_key Kafka::Protocol::DeleteTopicsRequest
#api_key Kafka::Protocol::ListGroupsRequest
#api_key Kafka::Protocol::SaslHandshakeRequest
#api_key Kafka::Protocol::MetadataRequest
#api_key Kafka::Protocol::DescribeGroupsRequest
#api_key Kafka::Protocol::FindCoordinatorRequest
#api_key Kafka::Protocol::HeartbeatRequest
#api_key Kafka::Protocol::AddOffsetsToTxnRequest
#api_key Kafka::Protocol::SyncGroupRequest
#api_key Kafka::Protocol::OffsetFetchRequest
#api_key Kafka::Protocol::InitProducerIDRequest
#api_key Kafka::Protocol::LeaveGroupRequest
#api_key Kafka::Protocol::DescribeConfigsRequest
#api_key Kafka::Protocol::ProduceRequest
#api_key Kafka::Protocol::ApiVersionsResponse::ApiInfo
#api_key Kafka::Protocol::JoinGroupRequest
#api_key Kafka::Protocol::AlterConfigsRequest
#api_key Kafka::Protocol::CreateTopicsRequest
#api_name Kafka::Protocol::ApiVersionsResponse::ApiInfo
api_name Kafka::Protocol
#api_version Kafka::Protocol::ProduceRequest
#api_version Kafka::Protocol::JoinGroupRequest
#api_version Kafka::Protocol::CreatePartitionsRequest
#api_version Kafka::Protocol::AlterConfigsRequest
#api_version Kafka::Protocol::OffsetFetchRequest
#api_version Kafka::Protocol::DescribeGroupsRequest
#api_version Kafka::Protocol::DeleteTopicsRequest
#api_version Kafka::Protocol::ListOffsetRequest
#api_version Kafka::Protocol::MetadataRequest
#api_version Kafka::Protocol::CreateTopicsRequest
#api_version Kafka::Protocol::FindCoordinatorRequest
#api_version Kafka::Protocol::ListGroupsRequest
#api_version Kafka::Protocol::DescribeConfigsRequest
#api_version Kafka::Protocol::OffsetCommitRequest
#api_version Kafka::Protocol::TxnOffsetCommitRequest
#api_version Kafka::Protocol::FetchRequest
#api_versions Kafka::Broker
#apis Kafka::Cluster
#apis Kafka::Protocol::ApiVersionsResponse
#apis Kafka::Client
#array Kafka::Protocol::Decoder
#assign Kafka::Protocol::MemberAssignment
#assign Kafka::ConsumerGroup::Assignor
#assigned_partitions Kafka::ConsumerGroup
#assigned_to? Kafka::ConsumerGroup
#async_producer Kafka::Client
#attributes Kafka::Protocol::Record
#attributes Kafka::Protocol::RecordBatch
#authenticate! Kafka::Sasl::Gssapi
#authenticate! Kafka::Sasl::AwsMskIam
#authenticate! Kafka::Sasl::Plain
#authenticate! Kafka::SaslAuthenticator
#authenticate! Kafka::Sasl::Scram
#authenticate! Kafka::Sasl::OAuth
#begin_transaction Kafka::Producer
#begin_transaction Kafka::TransactionManager
#boolean Kafka::Protocol::Decoder
#brokers Kafka::Protocol::MetadataResponse
#brokers Kafka::Client
#buffer_bytesize Kafka::Producer
#buffer_overflow Kafka::Datadog::ProducerSubscriber
#buffer_overflow Kafka::Prometheus::ProducerSubscriber
#buffer_overflow Kafka::Prometheus::AsyncProducerSubscriber
#buffer_overflow Kafka::Datadog::AsyncProducerSubscriber
#buffer_overflow Kafka::Statsd::AsyncProducerSubscriber
#buffer_overflow Kafka::Statsd::ProducerSubscriber
#buffer_size Kafka::Producer
build Kafka::SslContext
#build_connection Kafka::ConnectionBuilder
#bytes Kafka::Protocol::Decoder
#bytesize Kafka::MessageBuffer
#bytesize Kafka::Protocol::Record
#bytesize Kafka::PendingMessageQueue
#bytesize Kafka::PendingMessage
#bytesize Kafka::Protocol::Message
#call Kafka::RoundRobinAssignmentStrategy
#call Kafka::Partitioner
#call Kafka::Interceptors
#clear Kafka::PendingMessageQueue
#clear Kafka::MessageBuffer
#clear_buffer Kafka::Producer
#clear_messages Kafka::MessageBuffer
#clear_offsets Kafka::OffsetManager
#clear_offsets_excluding Kafka::OffsetManager
#clear_tags! Kafka::TaggedLogger
#clear_target_topics Kafka::Cluster
#client_host Kafka::Protocol::DescribeGroupsResponse::Member
#client_id Kafka::Protocol::DescribeGroupsResponse::Member
#close Kafka::Client
#close Kafka::SSLSocketWithTimeout
#close Kafka::Connection
#close Kafka::TransactionManager
#close Kafka::SocketWithTimeout
#close Kafka::BrokerPool
#closed? Kafka::SocketWithTimeout
#closed? Kafka::SSLSocketWithTimeout
#cluster_info Kafka::Cluster
#codec Kafka::Compressor
#codec_id Kafka::LZ4Codec
#codec_id Kafka::GzipCodec
#codec_id Kafka::SnappyCodec
#codec_id Kafka::ZstdCodec
#codec_id Kafka::Protocol::Message
#codec_id Kafka::Protocol::RecordBatch
codecs Kafka::Compression
#commit_offsets Kafka::ConsumerGroup
#commit_offsets Kafka::Broker
#commit_offsets Kafka::OffsetManager
#commit_offsets Kafka::Consumer
#commit_offsets_if_necessary Kafka::OffsetManager
#commit_transaction Kafka::TransactionManager
#commit_transaction Kafka::Producer
#committing_transaction? Kafka::TransactionStateMachine
#compress Kafka::LZ4Codec
#compress Kafka::Compressor
#compress Kafka::GzipCodec
#compress Kafka::SnappyCodec
#compress Kafka::ZstdCodec
#compressed? Kafka::Protocol::Message
#compressed? Kafka::Protocol::RecordBatch
#compressor Kafka::Protocol::ProduceRequest
#concat Kafka::MessageBuffer
#configs Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#configure Kafka::Fetcher
#configured? Kafka::Sasl::OAuth
#configured? Kafka::Sasl::Scram
#configured? Kafka::Sasl::AwsMskIam
#configured? Kafka::Sasl::Gssapi
#configured? Kafka::Sasl::Plain
#connect Kafka::BrokerPool
#connected? Kafka::Broker
#consumer Kafka::Client
#controller_broker Kafka::Client
#controller_broker Kafka::Protocol::MetadataResponse
#controller_id Kafka::Protocol::MetadataResponse
#coordinator_host Kafka::Protocol::FindCoordinatorResponse
#coordinator_id Kafka::Protocol::FindCoordinatorResponse
#coordinator_port Kafka::Protocol::FindCoordinatorResponse
#create_partitions Kafka::Broker
#create_partitions_for Kafka::Cluster
#create_partitions_for Kafka::Client
#create_time Kafka::Protocol::Message
#create_time Kafka::FetchedMessage
#create_time Kafka::PendingMessage
#create_time Kafka::Protocol::Record
#create_topic Kafka::Cluster
#create_topic Kafka::Client
#create_topics Kafka::Broker
#current_tags Kafka::TaggedLogger
#data? Kafka::Fetcher
decode Kafka::Protocol::MetadataResponse
decode Kafka::Protocol::AddOffsetsToTxnResponse
decode Kafka::Protocol::MessageSet
decode Kafka::Protocol::Message
decode Kafka::Protocol::ListGroupsResponse
decode Kafka::Protocol::LeaveGroupResponse
decode Kafka::Protocol::OffsetFetchResponse
decode Kafka::Protocol::HeartbeatResponse
decode Kafka::Protocol::ProduceResponse
decode Kafka::Protocol::EndTxnResposne
decode Kafka::Protocol::AlterConfigsResponse
decode Kafka::Protocol::DeleteTopicsResponse
decode Kafka::Protocol::MemberAssignment
decode Kafka::Protocol::OffsetCommitResponse
decode Kafka::Protocol::ApiVersionsResponse
decode Kafka::Protocol::RecordBatch
decode Kafka::Protocol::SyncGroupResponse
decode Kafka::Protocol::InitProducerIDResponse
decode Kafka::Protocol::FindCoordinatorResponse
decode Kafka::Protocol::AddPartitionsToTxnResponse
decode Kafka::Protocol::DescribeGroupsResponse
decode Kafka::Protocol::CreateTopicsResponse
decode Kafka::Protocol::DescribeConfigsResponse
decode Kafka::Protocol::Record
decode Kafka::Protocol::FetchResponse
decode Kafka::Protocol::JoinGroupResponse
decode Kafka::Protocol::CreatePartitionsResponse
decode Kafka::Protocol::ListOffsetResponse
decode Kafka::Protocol::SaslHandshakeResponse
decode Kafka::Protocol::TxnOffsetCommitResponse
#decoder Kafka::Connection
#decompress Kafka::SnappyCodec
#decompress Kafka::GzipCodec
#decompress Kafka::Protocol::Message
#decompress Kafka::ZstdCodec
#decompress Kafka::LZ4Codec
#delete_topic Kafka::Cluster
#delete_topic Kafka::Client
#delete_topics Kafka::Broker
#deliver_message Kafka::Client
#deliver_messages Kafka::Datadog::ProducerSubscriber
#deliver_messages Kafka::AsyncProducer
#deliver_messages Kafka::Producer
#deliver_messages Kafka::Statsd::ProducerSubscriber
#deliver_messages Kafka::Prometheus::ProducerSubscriber
#describe_configs Kafka::Cluster
#describe_configs Kafka::Client
#describe_configs Kafka::Broker
#describe_group Kafka::Cluster
#describe_group Kafka::Client
#describe_groups Kafka::Broker
#describe_topic Kafka::Cluster
#describe_topic Kafka::Client
#disconnect Kafka::Cluster
#disconnect Kafka::Broker
#drop_messages Kafka::Datadog::AsyncProducerSubscriber
#drop_messages Kafka::Statsd::AsyncProducerSubscriber
#drop_messages Kafka::Prometheus::AsyncProducerSubscriber
#each Kafka::PendingMessageQueue
#each Kafka::MessageBuffer
#each_batch Kafka::Consumer
#each_message Kafka::Consumer
#each_message Kafka::Client
#each_partition Kafka::Protocol::ProduceResponse
#empty? Kafka::PendingMessageQueue
#empty? Kafka::MessageBuffer
#empty? Kafka::FetchedBatch
#enabled? Kafka::SaslAuthenticator
#enabled_mechanisms Kafka::Protocol::SaslHandshakeResponse
#encode Kafka::Protocol::ListOffsetRequest
#encode Kafka::Protocol::LeaveGroupRequest
#encode Kafka::Protocol::OffsetCommitRequest
#encode Kafka::Protocol::FindCoordinatorRequest
#encode Kafka::Protocol::SyncGroupRequest
#encode Kafka::Protocol::FetchRequest
#encode Kafka::Protocol::MessageSet
#encode Kafka::Protocol::ApiVersionsRequest
#encode Kafka::Protocol::ListGroupsRequest
#encode Kafka::Protocol::DeleteTopicsRequest
#encode Kafka::Protocol::EndTxnRequest
#encode Kafka::Protocol::AddOffsetsToTxnRequest
#encode Kafka::Protocol::MetadataRequest
#encode Kafka::Protocol::AddPartitionsToTxnRequest
#encode Kafka::Protocol::RecordBatch
#encode Kafka::Protocol::DescribeConfigsRequest
#encode Kafka::Protocol::RequestMessage
#encode Kafka::Protocol::JoinGroupRequest
#encode Kafka::Protocol::ProduceRequest
#encode Kafka::Protocol::AlterConfigsRequest
#encode Kafka::Protocol::DescribeGroupsRequest
#encode Kafka::Protocol::MemberAssignment
#encode Kafka::Protocol::TxnOffsetCommitRequest
#encode Kafka::Protocol::CreateTopicsRequest
#encode Kafka::Protocol::Record
#encode Kafka::Protocol::Message
#encode Kafka::Protocol::OffsetFetchRequest
#encode Kafka::Protocol::InitProducerIDRequest
#encode Kafka::Protocol::CreatePartitionsRequest
#encode Kafka::Protocol::ConsumerGroupProtocol
#encode Kafka::Protocol::SaslHandshakeRequest
#encode Kafka::Protocol::HeartbeatRequest
#encode_record_array Kafka::Protocol::RecordBatch
#encode_record_batch_body Kafka::Protocol::RecordBatch
encode_with Kafka::Protocol::Encoder
#encoder Kafka::Connection
#end_txn Kafka::Broker
#enqueue_message Kafka::Prometheus::AsyncProducerSubscriber
#enqueue_message Kafka::Datadog::AsyncProducerSubscriber
#enqueue_message Kafka::Statsd::AsyncProducerSubscriber
#eof? Kafka::Protocol::Decoder
#error? Kafka::TransactionManager
#error? Kafka::TransactionStateMachine
#error_code Kafka::Protocol::ListGroupsResponse
#error_code Kafka::Protocol::DescribeGroupsResponse::Group
#error_code Kafka::Protocol::HeartbeatResponse
#error_code Kafka::Protocol::ApiVersionsResponse
#error_code Kafka::Protocol::DescribeGroupsResponse
#error_code Kafka::Protocol::SyncGroupResponse
#error_code Kafka::Protocol::AddOffsetsToTxnResponse
#error_code Kafka::Protocol::EndTxnResposne
#error_code Kafka::Protocol::SaslHandshakeResponse
#error_code Kafka::Protocol::AlterConfigsResponse::ResourceDescription
#error_code Kafka::Protocol::ProduceResponse::PartitionInfo
#error_code Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
#error_code Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
#error_code Kafka::Protocol::LeaveGroupResponse
#error_code Kafka::Protocol::FindCoordinatorResponse
#error_code Kafka::Protocol::TxnOffsetCommitResponse::PartitionError
#error_code Kafka::Protocol::InitProducerIDResponse
#error_code Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
#error_code Kafka::Protocol::JoinGroupResponse
#error_code Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#error_code Kafka::Protocol::FetchResponse::FetchedPartition
#error_message Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#error_message Kafka::Protocol::FindCoordinatorResponse
#error_message Kafka::Protocol::AlterConfigsResponse::ResourceDescription
#errors Kafka::Protocol::CreatePartitionsResponse
#errors Kafka::Protocol::DeleteTopicsResponse
#errors Kafka::Protocol::CreateTopicsResponse
#errors Kafka::Protocol::TxnOffsetCommitResponse
#errors Kafka::Protocol::AddPartitionsToTxnResponse
#execute Kafka::ProduceOperation
#execute Kafka::FetchOperation
#expired? Kafka::Pause
#failed_messages Kafka::DeliveryFailed
#fetch_batch Kafka::Prometheus::ConsumerSubscriber
#fetch_batch Kafka::Datadog::ConsumerSubscriber
#fetch_batch Kafka::Statsd::ConsumerSubscriber
#fetch_from_partition Kafka::FetchOperation
#fetch_group_offsets Kafka::Cluster
#fetch_group_offsets Kafka::Client
#fetch_messages Kafka::Client
#fetch_messages Kafka::Broker
#fetch_metadata Kafka::Broker
#fetch_offsets Kafka::ConsumerGroup
#fetch_offsets Kafka::Broker
#find_broker Kafka::Protocol::MetadataResponse
find_codec Kafka::Compression
find_codec_by_id Kafka::Compression
#find_coordinator Kafka::Broker
find_digest Kafka::Digest
#find_leader_id Kafka::Protocol::MetadataResponse
#first_offset Kafka::Protocol::FetchResponse::AbortedTransaction
#first_offset Kafka::Protocol::RecordBatch
#first_offset Kafka::FetchedBatch
#first_sequence Kafka::Protocol::RecordBatch
#first_timestamp Kafka::Protocol::RecordBatch
#flush Kafka::TaggedLogger
from_string Kafka::Protocol::Decoder
#fulfill_relative_data Kafka::Protocol::RecordBatch
#generate Kafka::FetchedBatchGenerator
#generation_id Kafka::Protocol::JoinGroupResponse
#generation_id Kafka::ConsumerGroup
#get_group_coordinator Kafka::Cluster
#get_leader Kafka::Cluster
#get_transaction_coordinator Kafka::Cluster
#group_id Kafka::Protocol::DescribeGroupsResponse::Group
#group_id Kafka::Protocol::ListGroupsResponse::GroupEntry
#group_id Kafka::ConsumerGroup
#group_protocol Kafka::Protocol::JoinGroupResponse
#groups Kafka::Protocol::ListGroupsResponse
#groups Kafka::Protocol::DescribeGroupsResponse
#groups Kafka::Client
handle_error Kafka::Protocol
#handshake_messages Kafka::Sasl::Gssapi
#has_topic? Kafka::Client
#hash Kafka::Crc32Hash
#hash Kafka::Murmur2Hash
#headers Kafka::Protocol::Record
#headers Kafka::FetchedMessage
#headers Kafka::PendingMessage
#headers Kafka::Protocol::Message
#heartbeat Kafka::Broker
#heartbeat Kafka::ConsumerGroup
#highwater_mark_offset Kafka::Protocol::FetchResponse::FetchedPartition
#highwater_mark_offset Kafka::FetchedBatch
#host Kafka::BrokerInfo
host Kafka::Datadog
host= Kafka::Datadog
host= Kafka::Statsd
#idempotent? Kafka::TransactionManager
#ident Kafka::Sasl::Gssapi
#ident Kafka::Sasl::Scram
#ident Kafka::Sasl::Plain
#ident Kafka::Sasl::OAuth
#ident Kafka::Sasl::AwsMskIam
#in_transaction Kafka::Protocol::RecordBatch
#in_transaction? Kafka::TransactionManager
#in_transaction? Kafka::TransactionStateMachine
#init_producer_id Kafka::TransactionManager
#init_producer_id Kafka::Broker
#init_transactions Kafka::Producer
#init_transactions Kafka::TransactionManager
#initialize Kafka::Protocol::InitProducerIDRequest
#initialize Kafka::Protocol::ProduceResponse::PartitionInfo
#initialize Kafka::Sasl::Gssapi
#initialize Kafka::Partitioner
#initialize Kafka::Protocol::FetchResponse::FetchedPartition
#initialize Kafka::BrokerInfo
#initialize Kafka::BrokerPool
#initialize Kafka::Protocol::AddOffsetsToTxnResponse
#initialize Kafka::Sasl::Scram
#initialize Kafka::Sasl::Plain
#initialize Kafka::Sasl::OAuth
#initialize Kafka::Instrumenter
#initialize Kafka::Protocol::ProduceRequest
#initialize Kafka::Prometheus::AsyncProducerSubscriber
#initialize Kafka::Prometheus::ProducerSubscriber
#initialize Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
#initialize Kafka::Prometheus::ConsumerSubscriber
#initialize Kafka::Prometheus::ConnectionSubscriber
#initialize Kafka::Protocol::JoinGroupRequest
#initialize Kafka::PendingMessage
#initialize Kafka::Protocol::TxnOffsetCommitResponse::TopicPartitionsError
#initialize Kafka::Protocol::MetadataResponse::TopicMetadata
#initialize Kafka::FetchedMessage
#initialize Kafka::FetchOperation
#initialize Kafka::Sasl::AwsMskIam
#initialize Kafka::Protocol::TxnOffsetCommitResponse
#initialize Kafka::OffsetManager
#initialize Kafka::Protocol::ListOffsetResponse
#initialize Kafka::MessageBuffer
#initialize Kafka::Protocol::HeartbeatRequest
#initialize Kafka::Protocol::CreatePartitionsResponse
#initialize Kafka::ConsumerGroup
#initialize Kafka::SSLSocketWithTimeout
#initialize Kafka::AsyncProducer::Worker
#initialize Kafka::AsyncProducer::Timer
#initialize Kafka::AsyncProducer
#initialize Kafka::Protocol::TxnOffsetCommitResponse::PartitionError
#initialize Kafka::TaggedLogger
#initialize Kafka::Protocol::ProduceResponse
#initialize Kafka::FetchedBatch
#initialize Kafka::TransactionStateMachine
#initialize Kafka::Protocol::OffsetCommitRequest
#initialize Kafka::Interceptors
#initialize Kafka::Protocol::JoinGroupResponse
#initialize Kafka::Protocol::FetchResponse::FetchedTopic
#initialize Kafka::Protocol::FetchResponse::AbortedTransaction
#initialize Kafka::Protocol::HeartbeatResponse
#initialize Kafka::TransactionManager
#initialize Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
#initialize Kafka::Protocol::OffsetCommitResponse
#initialize Kafka::Protocol::AddPartitionsToTxnResponse
#initialize Kafka::Protocol::Encoder
#initialize Kafka::Protocol::ConsumerGroupProtocol
#initialize Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
#initialize Kafka::Protocol::MetadataResponse::PartitionMetadata
#initialize Kafka::Protocol::Decoder
#initialize Kafka::Protocol::Record
#initialize Kafka::Protocol::InitProducerIDResponse
#initialize Kafka::Protocol::TxnOffsetCommitRequest
#initialize Kafka::Protocol::FetchRequest
#initialize Kafka::ProduceOperation
#initialize Kafka::ConnectionBuilder
#initialize Kafka::SaslAuthenticator
#initialize Kafka::Protocol::Message
#initialize Kafka::SocketWithTimeout
#initialize Kafka::Protocol::DeleteTopicsRequest
#initialize Kafka::Protocol::AddOffsetsToTxnRequest
#initialize Kafka::Protocol::EndTxnResposne
#initialize Kafka::FetchedBatchGenerator
#initialize Kafka::ConsumerGroup::Assignor
#initialize Kafka::Protocol::FindCoordinatorResponse
#initialize Kafka::Protocol::DescribeConfigsResponse
#initialize Kafka::Protocol::AddPartitionsToTxnRequest
#initialize Kafka::Connection
#initialize Kafka::Compressor
#initialize Kafka::Protocol::DescribeGroupsRequest
#initialize Kafka::Prometheus::FetcherSubscriber
#initialize Kafka::Heartbeat
#initialize Kafka::Protocol::ListGroupsResponse
#initialize Kafka::Protocol::RequestMessage
#initialize Kafka::Producer
#initialize Kafka::Protocol::AlterConfigsRequest
#initialize Kafka::Protocol::SaslHandshakeRequest
#initialize Kafka::FetchedOffsetResolver
#initialize Kafka::Protocol::FindCoordinatorRequest
#initialize Kafka::Protocol::ApiVersionsResponse::ApiInfo
#initialize Kafka::Consumer
#initialize Kafka::Fetcher
#initialize Kafka::Protocol::MemberAssignment
#initialize Kafka::Protocol::AlterConfigsResponse::ResourceDescription
#initialize Kafka::Protocol::ListGroupsResponse::GroupEntry
#initialize Kafka::Protocol::CreateTopicsRequest
#initialize Kafka::Protocol::SyncGroupResponse
#initialize Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#initialize Kafka::Protocol::DeleteTopicsResponse
#initialize Kafka::Protocol::DescribeGroupsResponse::Group
#initialize Kafka::Protocol::DescribeConfigsRequest
#initialize Kafka::Protocol::CreateTopicsResponse
#initialize Kafka::Protocol::CreatePartitionsRequest
#initialize Kafka::Protocol::LeaveGroupRequest
#initialize Kafka::Protocol::SaslHandshakeResponse
#initialize Kafka::Protocol::FetchResponse
#initialize Kafka::Protocol::DescribeGroupsResponse
#initialize Kafka::Protocol::ApiVersionsResponse
#initialize Kafka::Cluster
#initialize Kafka::Protocol::LeaveGroupResponse
#initialize Kafka::DecoratingInstrumenter
#initialize Kafka::Protocol::ListOffsetRequest
#initialize Kafka::Client
#initialize Kafka::Protocol::AlterConfigsResponse
#initialize Kafka::Protocol::MetadataRequest
#initialize Kafka::Broker
#initialize Kafka::Pause
#initialize Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
#initialize Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
#initialize Kafka::ProcessingError
#initialize Kafka::DeliveryFailed
#initialize Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#initialize Kafka::Protocol::MetadataResponse
#initialize Kafka::Protocol::EndTxnRequest
#initialize Kafka::Protocol::OffsetFetchResponse
#initialize Kafka::Protocol::RecordBatch
#initialize Kafka::Protocol::OffsetFetchRequest
#initialize Kafka::Protocol::ProduceResponse::TopicInfo
#initialize Kafka::PendingMessageQueue
#initialize Kafka::Protocol::MessageSet
#initialize Kafka::Protocol::DescribeGroupsResponse::Member
#initialize Kafka::Protocol::SyncGroupRequest
#initialize_gssapi_context Kafka::Sasl::Gssapi
#inspect Kafka::Protocol::ApiVersionsResponse::ApiInfo
#instrument Kafka::DecoratingInstrumenter
#instrument Kafka::Instrumenter
#int16 Kafka::Protocol::Decoder
#int32 Kafka::Protocol::Decoder
#int64 Kafka::Protocol::Decoder
#int8 Kafka::Protocol::Decoder
#is_control_batch Kafka::Protocol::RecordBatch
#is_control_record Kafka::Protocol::Message
#is_control_record Kafka::FetchedMessage
#is_control_record Kafka::Protocol::Record
#is_default Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#is_sensitive Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#join Kafka::ConsumerGroup
#join_group Kafka::Prometheus::ConsumerSubscriber
#join_group Kafka::Datadog::ConsumerSubscriber
#join_group Kafka::Statsd::ConsumerSubscriber
#join_group Kafka::Broker
#key Kafka::Protocol::Message
#key Kafka::Protocol::Record
#key Kafka::PendingMessage
#key Kafka::FetchedMessage
#last_offset Kafka::FetchedBatch
#last_offset Kafka::Protocol::RecordBatch
#last_offset_delta Kafka::Protocol::RecordBatch
#last_offset_for Kafka::Client
#last_offsets_for Kafka::Client
#last_stable_offset Kafka::Protocol::FetchResponse::FetchedPartition
#leader Kafka::Protocol::MetadataResponse::PartitionMetadata
#leader_epoch Kafka::FetchedBatch
#leader_id Kafka::Protocol::JoinGroupResponse
#leave Kafka::ConsumerGroup
#leave_group Kafka::Prometheus::ConsumerSubscriber
#leave_group Kafka::Datadog::ConsumerSubscriber
#leave_group Kafka::Statsd::ConsumerSubscriber
#leave_group Kafka::Broker
#list_groups Kafka::Cluster
#list_groups Kafka::Broker
#list_offsets Kafka::Broker
#list_topics Kafka::Cluster
#load Kafka::SnappyCodec
#load Kafka::Murmur2Hash
#load Kafka::ZstdCodec
#load Kafka::GzipCodec
#load Kafka::Crc32Hash
#load Kafka::LZ4Codec
#load_gssapi Kafka::Sasl::Gssapi
#loop Kafka::Prometheus::FetcherSubscriber
#loop Kafka::Datadog::FetcherSubscriber
#loop Kafka::Datadog::ConsumerSubscriber
#loop Kafka::Statsd::FetcherSubscriber
#mark_as_processed Kafka::OffsetManager
#mark_as_stale! Kafka::Cluster
#mark_control_record Kafka::Protocol::RecordBatch
#mark_message_as_processed Kafka::Consumer
#max_timestamp Kafka::Protocol::RecordBatch
#max_version Kafka::Protocol::ApiVersionsResponse::ApiInfo
#max_wait_time Kafka::Fetcher
#member? Kafka::ConsumerGroup
#member_assignment Kafka::Protocol::DescribeGroupsResponse::Member
#member_assignment Kafka::Protocol::SyncGroupResponse
#member_id Kafka::Protocol::DescribeGroupsResponse::Member
#member_id Kafka::Protocol::JoinGroupResponse
#members Kafka::Protocol::DescribeGroupsResponse::Group
#members Kafka::Protocol::JoinGroupResponse
#messages Kafka::FetchedBatch
#messages Kafka::Protocol::FetchResponse::FetchedPartition
#messages Kafka::Protocol::MessageSet
#messages_for Kafka::MessageBuffer
#messages_for_topics Kafka::Protocol::ProduceRequest
#metadata Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
#min_version Kafka::Protocol::ApiVersionsResponse::ApiInfo
#name Kafka::Protocol::AlterConfigsResponse::ResourceDescription
#name Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#name Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
#name Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#name Kafka::Protocol::FetchResponse::FetchedTopic
namespace Kafka::Datadog
namespace= Kafka::Datadog
namespace= Kafka::Statsd
new Kafka::TaggedLogger
new Kafka
#next_offset_for Kafka::OffsetManager
#next_sequence_for Kafka::TransactionManager
#node_id Kafka::BrokerInfo
#offset Kafka::Protocol::Message
#offset Kafka::Protocol::Record
#offset Kafka::FetchedMessage
#offset Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
#offset Kafka::OffsetOutOfRange
#offset Kafka::ProcessingError
#offset Kafka::Protocol::ProduceResponse::PartitionInfo
#offset Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
#offset_delta Kafka::Protocol::Record
#offset_for Kafka::Protocol::OffsetFetchResponse
#offset_for Kafka::Protocol::ListOffsetResponse
#offset_lag Kafka::FetchedBatch
#open? Kafka::Connection
parse Kafka::BrokerUri
#partition Kafka::Protocol::TxnOffsetCommitResponse::PartitionError
#partition Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
#partition Kafka::PendingMessage
#partition Kafka::FetchedMessage
#partition Kafka::FetchedBatch
#partition Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
#partition Kafka::OffsetOutOfRange
#partition Kafka::ProcessingError
#partition Kafka::Protocol::FetchResponse::FetchedPartition
#partition Kafka::Protocol::ProduceResponse::PartitionInfo
#partition_error_code Kafka::Protocol::MetadataResponse::PartitionMetadata
#partition_id Kafka::Protocol::MetadataResponse::PartitionMetadata
#partition_id Kafka::ConsumerGroup::Assignor::Partition
#partition_key Kafka::PendingMessage
#partition_leader_epoch Kafka::Protocol::RecordBatch
#partition_offsets Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
#partitions Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
#partitions Kafka::Protocol::TxnOffsetCommitResponse::TopicPartitionsError
#partitions Kafka::Protocol::MetadataResponse::TopicMetadata
#partitions Kafka::Protocol::ProduceResponse::TopicInfo
#partitions Kafka::Protocol::FetchResponse::FetchedTopic
#partitions_for Kafka::Cluster
#partitions_for Kafka::Client
#partitions_for Kafka::Protocol::MetadataResponse
#pause Kafka::Consumer
#pause! Kafka::Pause
#pause_duration Kafka::Pause
#pause_status Kafka::Prometheus::ConsumerSubscriber
#pause_status Kafka::Datadog::ConsumerSubscriber
#pause_status Kafka::Statsd::ConsumerSubscriber
#paused? Kafka::Consumer
#paused? Kafka::Pause
#peek Kafka::Protocol::Decoder
#poll Kafka::Fetcher
#pop_tags Kafka::TaggedLogger
#port Kafka::BrokerInfo
port Kafka::Datadog
port= Kafka::Datadog
port= Kafka::Statsd
#process_batch Kafka::Prometheus::ConsumerSubscriber
#process_batch Kafka::Datadog::ConsumerSubscriber
#process_batch Kafka::Statsd::ConsumerSubscriber
#process_message Kafka::Prometheus::ConsumerSubscriber
#process_message Kafka::Datadog::ConsumerSubscriber
#process_message Kafka::Statsd::ConsumerSubscriber
#produce Kafka::AsyncProducer
#produce Kafka::Producer
#produce Kafka::Broker
#produce_api_min_version Kafka::SnappyCodec
#produce_api_min_version Kafka::ZstdCodec
#produce_api_min_version Kafka::LZ4Codec
#produce_api_min_version Kafka::GzipCodec
#produce_message Kafka::Prometheus::ProducerSubscriber
#produce_message Kafka::Datadog::ProducerSubscriber
#produce_message Kafka::Statsd::ProducerSubscriber
#producer Kafka::Client
#producer_epoch Kafka::TransactionManager
#producer_epoch Kafka::Protocol::InitProducerIDResponse
#producer_epoch Kafka::Protocol::RecordBatch
#producer_id Kafka::TransactionManager
#producer_id Kafka::Protocol::InitProducerIDResponse
#producer_id Kafka::Protocol::FetchResponse::AbortedTransaction
#producer_id Kafka::Protocol::RecordBatch
#protocol Kafka::Protocol::DescribeGroupsResponse::Group
#protocol_name Kafka::RoundRobinAssignmentStrategy
#protocol_name Kafka::ConsumerGroup::Assignor
#protocol_type Kafka::Protocol::ListGroupsResponse::GroupEntry
#push_tags Kafka::TaggedLogger
#queue Kafka::Fetcher
#read Kafka::SocketWithTimeout
#read Kafka::Protocol::Decoder
#read Kafka::SSLSocketWithTimeout
#read_only Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#ready? Kafka::TransactionStateMachine
#ready? Kafka::TransactionManager
#records Kafka::Protocol::RecordBatch
#refresh_metadata! Kafka::Cluster
#refresh_metadata_if_necessary! Kafka::Cluster
registry Kafka::Prometheus
#replace Kafka::PendingMessageQueue
#replica_count_for Kafka::Client
#replicas Kafka::Protocol::MetadataResponse::PartitionMetadata
#request Kafka::Prometheus::ConnectionSubscriber
#request Kafka::Datadog::ConnectionSubscriber
#request Kafka::Statsd::ConnectionSubscriber
#required_acks Kafka::Protocol::ProduceRequest
#requires_acks? Kafka::Protocol::ProduceRequest
#reset Kafka::Fetcher
#reset! Kafka::Pause
#resolve! Kafka::FetchedOffsetResolver
#resolve_offset Kafka::Cluster
#resolve_offsets Kafka::Cluster
#resources Kafka::Protocol::AlterConfigsResponse
#resources Kafka::Protocol::DescribeConfigsResponse
#response_class Kafka::Protocol::DescribeGroupsRequest
#response_class Kafka::Protocol::AddPartitionsToTxnRequest
#response_class Kafka::Protocol::TxnOffsetCommitRequest
#response_class Kafka::Protocol::CreatePartitionsRequest
#response_class Kafka::Protocol::DescribeConfigsRequest
#response_class Kafka::Protocol::SaslHandshakeRequest
#response_class Kafka::Protocol::ListGroupsRequest
#response_class Kafka::Protocol::FetchRequest
#response_class Kafka::Protocol::CreateTopicsRequest
#response_class Kafka::Protocol::FindCoordinatorRequest
#response_class Kafka::Protocol::SyncGroupRequest
#response_class Kafka::Protocol::JoinGroupRequest
#response_class Kafka::Protocol::AddOffsetsToTxnRequest
#response_class Kafka::Protocol::HeartbeatRequest
#response_class Kafka::Protocol::MetadataRequest
#response_class Kafka::Protocol::ProduceRequest
#response_class Kafka::Protocol::EndTxnRequest
#response_class Kafka::Protocol::AlterConfigsRequest
#response_class Kafka::Protocol::OffsetFetchRequest
#response_class Kafka::Protocol::InitProducerIDRequest
#response_class Kafka::Protocol::ApiVersionsRequest
#response_class Kafka::Protocol::ListOffsetRequest
#response_class Kafka::Protocol::LeaveGroupRequest
#response_class Kafka::Protocol::OffsetCommitRequest
#response_class Kafka::Protocol::DeleteTopicsRequest
#resume Kafka::Consumer
#resume! Kafka::Pause
#run Kafka::AsyncProducer::Worker
#run Kafka::AsyncProducer::Timer
#seek Kafka::Fetcher
#seek Kafka::Consumer
#seek_to Kafka::OffsetManager
#seek_to_default Kafka::OffsetManager
#select_with_timeout Kafka::SSLSocketWithTimeout
#send_and_receive_sasl_token Kafka::Sasl::Gssapi
#send_offsets_to_transaction Kafka::Producer
#send_offsets_to_txn Kafka::TransactionManager
#send_request Kafka::Connection
#set_default_offset Kafka::OffsetManager
#set_encoding Kafka::SSLSocketWithTimeout
#set_encoding Kafka::SocketWithTimeout
#shutdown Kafka::AsyncProducer
#shutdown Kafka::Producer
#size Kafka::Protocol::MessageSet
#size Kafka::PendingMessageQueue
#size Kafka::Protocol::RecordBatch
#size Kafka::MessageBuffer
socket_path Kafka::Datadog
socket_path= Kafka::Datadog
start Kafka::Prometheus
#start Kafka::Fetcher
#state Kafka::Protocol::DescribeGroupsResponse::Group
statsd Kafka::Datadog
statsd Kafka::Statsd
statsd= Kafka::Datadog
#stop Kafka::Consumer
#stop Kafka::Fetcher
#string Kafka::Protocol::Decoder
#subscribe Kafka::ConsumerGroup
#subscribe Kafka::Consumer
#subscribe Kafka::Fetcher
#subscribed_partitions Kafka::ConsumerGroup
#supports_api? Kafka::Cluster
#supports_api? Kafka::Client
#sync_group Kafka::Prometheus::ConsumerSubscriber
#sync_group Kafka::Datadog::ConsumerSubscriber
#sync_group Kafka::Statsd::ConsumerSubscriber
#sync_group Kafka::Broker
#tagged Kafka::TaggedLogger
tags Kafka::Datadog
tags= Kafka::Datadog
#tags_text Kafka::TaggedLogger
#throttle_time_ms Kafka::Protocol::ProduceResponse
#timeout Kafka::Protocol::ProduceRequest
#timestamp Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
#timestamp Kafka::Protocol::ProduceResponse::PartitionInfo
#timestamp_delta Kafka::Protocol::Record
#to_h Kafka::MessageBuffer
#to_s Kafka::Protocol::ApiVersionsResponse::ApiInfo
#to_s Kafka::ConsumerGroup
#to_s Kafka::BrokerInfo
#to_s Kafka::Connection
#to_s Kafka::Producer
#to_s Kafka::Broker
#topic Kafka::Protocol::ProduceResponse::TopicInfo
#topic Kafka::ConsumerGroup::Assignor::Partition
#topic Kafka::Protocol::TxnOffsetCommitResponse::TopicPartitionsError
#topic Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
#topic Kafka::PendingMessage
#topic Kafka::FetchedMessage
#topic Kafka::FetchedBatch
#topic Kafka::ProcessingError
#topic Kafka::OffsetOutOfRange
#topic_error Kafka::Prometheus::ProducerSubscriber
#topic_error Kafka::Datadog::ProducerSubscriber
#topic_error Kafka::Statsd::ProducerSubscriber
#topic_error_code Kafka::Protocol::MetadataResponse::TopicMetadata
#topic_name Kafka::Protocol::MetadataResponse::TopicMetadata
#topics Kafka::Protocol::OffsetFetchResponse
#topics Kafka::Protocol::ListOffsetResponse
#topics Kafka::Protocol::MetadataResponse
#topics Kafka::Protocol::JoinGroupResponse::Metadata
#topics Kafka::Protocol::MemberAssignment
#topics Kafka::Protocol::ProduceResponse
#topics Kafka::Protocol::FetchResponse
#topics Kafka::Protocol::OffsetCommitResponse
#topics Kafka::Cluster
#topics Kafka::Client
#transaction Kafka::Producer
#transactional? Kafka::TransactionManager
#transactional_id Kafka::Protocol::ProduceRequest
#transactional_id Kafka::TransactionManager
#transition_to! Kafka::TransactionStateMachine
#trigger Kafka::Heartbeat
#trigger! Kafka::Heartbeat
#trigger_heartbeat Kafka::Consumer
#trigger_heartbeat! Kafka::Consumer
#txn_offset_commit Kafka::Broker
#type Kafka::Protocol::AlterConfigsResponse::ResourceDescription
#type Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
#uninitialized? Kafka::TransactionStateMachine
#unknown_last_offset? Kafka::FetchedBatch
#update_sequence_for Kafka::TransactionManager
#user_data Kafka::Protocol::JoinGroupResponse::Metadata
#user_data Kafka::ConsumerGroup::Assignor
#valid_sorted_partitions Kafka::RoundRobinAssignmentStrategy
#value Kafka::Protocol::Message
#value Kafka::Protocol::Record
#value Kafka::PendingMessage
#value Kafka::FetchedMessage
#value Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
#varint Kafka::Protocol::Decoder
#varint_array Kafka::Protocol::Decoder
#varint_bytes Kafka::Protocol::Decoder
#varint_string Kafka::Protocol::Decoder
#version Kafka::Protocol::JoinGroupResponse::Metadata
#version_supported? Kafka::Protocol::ApiVersionsResponse::ApiInfo
#write Kafka::SSLSocketWithTimeout
#write Kafka::PendingMessageQueue
#write Kafka::SocketWithTimeout
#write Kafka::Protocol::Encoder
#write Kafka::MessageBuffer
#write_array Kafka::Protocol::Encoder
#write_boolean Kafka::Protocol::Encoder
#write_bytes Kafka::Protocol::Encoder
#write_int16 Kafka::Protocol::Encoder
#write_int32 Kafka::Protocol::Encoder
#write_int64 Kafka::Protocol::Encoder
#write_int8 Kafka::Protocol::Encoder
#write_string Kafka::Protocol::Encoder
#write_varint Kafka::Protocol::Encoder
#write_varint_array Kafka::Protocol::Encoder
#write_varint_bytes Kafka::Protocol::Encoder
#write_varint_string Kafka::Protocol::Encoder