Table of Contents - ruby-kafka-custom-0.7.7.26 Documentation
Classes and Modules
- Kafka
- Kafka::AsyncProducer
- Kafka::AsyncProducer::Timer
- Kafka::AsyncProducer::Worker
- Kafka::Broker
- Kafka::BrokerInfo
- Kafka::BrokerPool
- Kafka::BrokerUri
- Kafka::Client
- Kafka::Cluster
- Kafka::Compression
- Kafka::Compressor
- Kafka::Connection
- Kafka::ConnectionBuilder
- Kafka::Consumer
- Kafka::ConsumerGroup
- Kafka::Datadog
- Kafka::Datadog::AsyncProducerSubscriber
- Kafka::Datadog::ConnectionSubscriber
- Kafka::Datadog::ConsumerSubscriber
- Kafka::Datadog::FetcherSubscriber
- Kafka::Datadog::ProducerSubscriber
- Kafka::Datadog::StatsdSubscriber
- Kafka::DecoratingInstrumenter
- Kafka::FetchOperation
- Kafka::FetchedBatch
- Kafka::FetchedBatchGenerator
- Kafka::FetchedMessage
- Kafka::FetchedOffsetResolver
- Kafka::Fetcher
- Kafka::GzipCodec
- Kafka::Heartbeat
- Kafka::Instrumenter
- Kafka::LZ4Codec
- Kafka::MessageBuffer
- Kafka::OffsetManager
- Kafka::Partitioner
- Kafka::Pause
- Kafka::PendingMessage
- Kafka::PendingMessageQueue
- Kafka::ProduceOperation
- Kafka::Producer
- Kafka::Producer::AbortTransaction
- Kafka::Protocol
- Kafka::Protocol::AddPartitionsToTxnRequest
- Kafka::Protocol::AddPartitionsToTxnResponse
- Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
- Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
- Kafka::Protocol::AlterConfigsRequest
- Kafka::Protocol::AlterConfigsResponse
- Kafka::Protocol::AlterConfigsResponse::ResourceDescription
- Kafka::Protocol::ApiVersionsRequest
- Kafka::Protocol::ApiVersionsResponse
- Kafka::Protocol::ApiVersionsResponse::ApiInfo
- Kafka::Protocol::ConsumerGroupProtocol
- Kafka::Protocol::CreatePartitionsRequest
- Kafka::Protocol::CreatePartitionsResponse
- Kafka::Protocol::CreateTopicsRequest
- Kafka::Protocol::CreateTopicsResponse
- Kafka::Protocol::Decoder
- Kafka::Protocol::DeleteTopicsRequest
- Kafka::Protocol::DeleteTopicsResponse
- Kafka::Protocol::DescribeConfigsRequest
- Kafka::Protocol::DescribeConfigsResponse
- Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
- Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
- Kafka::Protocol::DescribeGroupsRequest
- Kafka::Protocol::DescribeGroupsResponse
- Kafka::Protocol::DescribeGroupsResponse::Group
- Kafka::Protocol::DescribeGroupsResponse::Member
- Kafka::Protocol::Encoder
- Kafka::Protocol::EndTxnRequest
- Kafka::Protocol::EndTxnResposne
- Kafka::Protocol::FetchRequest
- Kafka::Protocol::FetchResponse
- Kafka::Protocol::FetchResponse::AbortedTransaction
- Kafka::Protocol::FetchResponse::FetchedPartition
- Kafka::Protocol::FetchResponse::FetchedTopic
- Kafka::Protocol::FindCoordinatorRequest
- Kafka::Protocol::FindCoordinatorResponse
- Kafka::Protocol::HeartbeatRequest
- Kafka::Protocol::HeartbeatResponse
- Kafka::Protocol::InitProducerIDRequest
- Kafka::Protocol::InitProducerIDResponse
- Kafka::Protocol::JoinGroupRequest
- Kafka::Protocol::JoinGroupResponse
- Kafka::Protocol::LeaveGroupRequest
- Kafka::Protocol::LeaveGroupResponse
- Kafka::Protocol::ListGroupsRequest
- Kafka::Protocol::ListGroupsResponse
- Kafka::Protocol::ListGroupsResponse::GroupEntry
- Kafka::Protocol::ListOffsetRequest
- Kafka::Protocol::ListOffsetResponse
- Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
- Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
- Kafka::Protocol::MemberAssignment
- Kafka::Protocol::Message
- Kafka::Protocol::MessageSet
- Kafka::Protocol::MetadataRequest
- Kafka::Protocol::MetadataResponse
- Kafka::Protocol::MetadataResponse::PartitionMetadata
- Kafka::Protocol::MetadataResponse::TopicMetadata
- Kafka::Protocol::OffsetCommitRequest
- Kafka::Protocol::OffsetCommitResponse
- Kafka::Protocol::OffsetFetchRequest
- Kafka::Protocol::OffsetFetchResponse
- Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
- Kafka::Protocol::ProduceRequest
- Kafka::Protocol::ProduceResponse
- Kafka::Protocol::ProduceResponse::PartitionInfo
- Kafka::Protocol::ProduceResponse::TopicInfo
- Kafka::Protocol::Record
- Kafka::Protocol::RecordBatch
- Kafka::Protocol::RequestMessage
- Kafka::Protocol::SaslHandshakeRequest
- Kafka::Protocol::SaslHandshakeResponse
- Kafka::Protocol::SyncGroupRequest
- Kafka::Protocol::SyncGroupResponse
- Kafka::RoundRobinAssignmentStrategy
- Kafka::SSLSocketWithTimeout
- Kafka::Sasl
- Kafka::Sasl::Gssapi
- Kafka::Sasl::OAuth
- Kafka::Sasl::Plain
- Kafka::Sasl::Scram
- Kafka::SaslAuthenticator
- Kafka::SnappyCodec
- Kafka::SocketWithTimeout
- Kafka::SslContext
- Kafka::Statsd
- Kafka::Statsd::AsyncProducerSubscriber
- Kafka::Statsd::ConnectionSubscriber
- Kafka::Statsd::ConsumerSubscriber
- Kafka::Statsd::FetcherSubscriber
- Kafka::Statsd::ProducerSubscriber
- Kafka::Statsd::StatsdSubscriber
- Kafka::TaggedFormatter
- Kafka::TaggedLogger
- Kafka::TransactionManager
- Kafka::TransactionStateMachine
- Kafka::TransactionStateMachine::InvalidStateError
- Kafka::TransactionStateMachine::InvalidTransitionError
Methods
- ::api_name — Kafka::Protocol
- ::build — Kafka::SslContext
- ::clear — Kafka::Datadog
- ::codecs — Kafka::Compression
- ::decode — Kafka::Protocol::AddPartitionsToTxnResponse
- ::decode — Kafka::Protocol::AlterConfigsResponse
- ::decode — Kafka::Protocol::ApiVersionsResponse
- ::decode — Kafka::Protocol::CreatePartitionsResponse
- ::decode — Kafka::Protocol::CreateTopicsResponse
- ::decode — Kafka::Protocol::DeleteTopicsResponse
- ::decode — Kafka::Protocol::DescribeConfigsResponse
- ::decode — Kafka::Protocol::DescribeGroupsResponse
- ::decode — Kafka::Protocol::EndTxnResposne
- ::decode — Kafka::Protocol::FetchResponse
- ::decode — Kafka::Protocol::FindCoordinatorResponse
- ::decode — Kafka::Protocol::HeartbeatResponse
- ::decode — Kafka::Protocol::InitProducerIDResponse
- ::decode — Kafka::Protocol::JoinGroupResponse
- ::decode — Kafka::Protocol::LeaveGroupResponse
- ::decode — Kafka::Protocol::ListGroupsResponse
- ::decode — Kafka::Protocol::ListOffsetResponse
- ::decode — Kafka::Protocol::MemberAssignment
- ::decode — Kafka::Protocol::Message
- ::decode — Kafka::Protocol::MessageSet
- ::decode — Kafka::Protocol::MetadataResponse
- ::decode — Kafka::Protocol::OffsetCommitResponse
- ::decode — Kafka::Protocol::OffsetFetchResponse
- ::decode — Kafka::Protocol::ProduceResponse
- ::decode — Kafka::Protocol::Record
- ::decode — Kafka::Protocol::RecordBatch
- ::decode — Kafka::Protocol::SaslHandshakeResponse
- ::decode — Kafka::Protocol::SyncGroupResponse
- ::default_host — Kafka::Datadog
- ::default_port — Kafka::Datadog
- ::encode_with — Kafka::Protocol::Encoder
- ::find_codec — Kafka::Compression
- ::find_codec_by_id — Kafka::Compression
- ::from_string — Kafka::Protocol::Decoder
- ::handle_error — Kafka::Protocol
- ::host — Kafka::Datadog
- ::host= — Kafka::Datadog
- ::host= — Kafka::Statsd
- ::namespace — Kafka::Datadog
- ::namespace= — Kafka::Datadog
- ::namespace= — Kafka::Statsd
- ::new — Kafka::AsyncProducer
- ::new — Kafka::AsyncProducer::Timer
- ::new — Kafka::AsyncProducer::Worker
- ::new — Kafka::Broker
- ::new — Kafka::BrokerInfo
- ::new — Kafka::BrokerPool
- ::new — Kafka::Client
- ::new — Kafka::Cluster
- ::new — Kafka::Compressor
- ::new — Kafka::Connection
- ::new — Kafka::ConnectionBuilder
- ::new — Kafka::Consumer
- ::new — Kafka::ConsumerGroup
- ::new — Kafka::FetchOperation
- ::new — Kafka::FetchedBatch
- ::new — Kafka::FetchedBatchGenerator
- ::new — Kafka::FetchedMessage
- ::new — Kafka::FetchedOffsetResolver
- ::new — Kafka::Fetcher
- ::new — Kafka::Heartbeat
- ::new — Kafka::Instrumenter
- ::new — Kafka::DecoratingInstrumenter
- ::new — Kafka::MessageBuffer
- ::new — Kafka::OffsetManager
- ::new — Kafka::Pause
- ::new — Kafka::PendingMessage
- ::new — Kafka::PendingMessageQueue
- ::new — Kafka::ProduceOperation
- ::new — Kafka::Producer
- ::new — Kafka::Protocol::AddPartitionsToTxnRequest
- ::new — Kafka::Protocol::AddPartitionsToTxnResponse
- ::new — Kafka::Protocol::AddPartitionsToTxnResponse::PartitionError
- ::new — Kafka::Protocol::AddPartitionsToTxnResponse::TopicPartitionsError
- ::new — Kafka::Protocol::AlterConfigsRequest
- ::new — Kafka::Protocol::AlterConfigsResponse
- ::new — Kafka::Protocol::AlterConfigsResponse::ResourceDescription
- ::new — Kafka::Protocol::ApiVersionsResponse
- ::new — Kafka::Protocol::ApiVersionsResponse::ApiInfo
- ::new — Kafka::Protocol::ConsumerGroupProtocol
- ::new — Kafka::Protocol::CreatePartitionsRequest
- ::new — Kafka::Protocol::CreatePartitionsResponse
- ::new — Kafka::Protocol::CreateTopicsRequest
- ::new — Kafka::Protocol::CreateTopicsResponse
- ::new — Kafka::Protocol::Decoder
- ::new — Kafka::Protocol::DeleteTopicsRequest
- ::new — Kafka::Protocol::DeleteTopicsResponse
- ::new — Kafka::Protocol::DescribeConfigsRequest
- ::new — Kafka::Protocol::DescribeConfigsResponse
- ::new — Kafka::Protocol::DescribeConfigsResponse::ResourceDescription
- ::new — Kafka::Protocol::DescribeConfigsResponse::ConfigEntry
- ::new — Kafka::Protocol::DescribeGroupsRequest
- ::new — Kafka::Protocol::DescribeGroupsResponse
- ::new — Kafka::Protocol::DescribeGroupsResponse::Group
- ::new — Kafka::Protocol::DescribeGroupsResponse::Member
- ::new — Kafka::Protocol::Encoder
- ::new — Kafka::Protocol::EndTxnRequest
- ::new — Kafka::Protocol::EndTxnResposne
- ::new — Kafka::Protocol::FetchRequest
- ::new — Kafka::Protocol::FetchResponse
- ::new — Kafka::Protocol::FetchResponse::FetchedPartition
- ::new — Kafka::Protocol::FetchResponse::FetchedTopic
- ::new — Kafka::Protocol::FetchResponse::AbortedTransaction
- ::new — Kafka::Protocol::FindCoordinatorRequest
- ::new — Kafka::Protocol::FindCoordinatorResponse
- ::new — Kafka::Protocol::HeartbeatRequest
- ::new — Kafka::Protocol::HeartbeatResponse
- ::new — Kafka::Protocol::InitProducerIDRequest
- ::new — Kafka::Protocol::InitProducerIDResponse
- ::new — Kafka::Protocol::JoinGroupRequest
- ::new — Kafka::Protocol::JoinGroupResponse
- ::new — Kafka::Protocol::LeaveGroupRequest
- ::new — Kafka::Protocol::LeaveGroupResponse
- ::new — Kafka::Protocol::ListGroupsResponse
- ::new — Kafka::Protocol::ListGroupsResponse::GroupEntry
- ::new — Kafka::Protocol::ListOffsetRequest
- ::new — Kafka::Protocol::ListOffsetResponse
- ::new — Kafka::Protocol::ListOffsetResponse::TopicOffsetInfo
- ::new — Kafka::Protocol::ListOffsetResponse::PartitionOffsetInfo
- ::new — Kafka::Protocol::MemberAssignment
- ::new — Kafka::Protocol::Message
- ::new — Kafka::Protocol::MessageSet
- ::new — Kafka::Protocol::MetadataRequest
- ::new — Kafka::Protocol::MetadataResponse
- ::new — Kafka::Protocol::MetadataResponse::PartitionMetadata
- ::new — Kafka::Protocol::MetadataResponse::TopicMetadata
- ::new — Kafka::Protocol::OffsetCommitRequest
- ::new — Kafka::Protocol::OffsetCommitResponse
- ::new — Kafka::Protocol::OffsetFetchRequest
- ::new — Kafka::Protocol::OffsetFetchResponse
- ::new — Kafka::Protocol::OffsetFetchResponse::PartitionOffsetInfo
- ::new — Kafka::Protocol::ProduceRequest
- ::new — Kafka::Protocol::ProduceResponse
- ::new — Kafka::Protocol::ProduceResponse::TopicInfo
- ::new — Kafka::Protocol::ProduceResponse::PartitionInfo
- ::new — Kafka::Protocol::Record
- ::new — Kafka::Protocol::RecordBatch
- ::new — Kafka::Protocol::RequestMessage
- ::new — Kafka::Protocol::SaslHandshakeRequest
- ::new — Kafka::Protocol::SaslHandshakeResponse
- ::new — Kafka::Protocol::SyncGroupRequest
- ::new — Kafka::Protocol::SyncGroupResponse
- ::new — Kafka::RoundRobinAssignmentStrategy
- ::new — Kafka::Sasl::Gssapi
- ::new — Kafka::Sasl::OAuth
- ::new — Kafka::Sasl::Plain
- ::new — Kafka::Sasl::Scram
- ::new — Kafka::SaslAuthenticator
- ::new — Kafka::SocketWithTimeout
- ::new — Kafka::SSLSocketWithTimeout
- ::new — Kafka::TransactionManager
- ::new — Kafka::TransactionStateMachine
- ::new — Kafka::TaggedLogger
- ::parse — Kafka::BrokerUri
- ::partition_for_key — Kafka::Partitioner
- ::port — Kafka::Datadog
- ::port= — Kafka::Datadog
- ::port= — Kafka::Statsd
- ::statsd — Kafka::Datadog
- ::statsd — Kafka::Statsd
- ::statsd= — Kafka::Datadog
- ::tags — Kafka::Datadog
- ::tags= — Kafka::Datadog
- #== — Kafka::PendingMessage
- #== — Kafka::Protocol::Message
- #== — Kafka::Protocol::MessageSet
- #== — Kafka::Protocol::Record
- #== — Kafka::Protocol::RecordBatch
- #abort_marker? — Kafka::FetchedBatchGenerator
- #abort_transaction — Kafka::Producer
- #abort_transaction — Kafka::TransactionManager
- #aborting_transaction? — Kafka::TransactionStateMachine
- #ack_message — Kafka::Datadog::ProducerSubscriber
- #ack_message — Kafka::Statsd::ProducerSubscriber
- #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_topic — Kafka::Client
- #alter_topic — Kafka::Cluster
- #api_info — Kafka::Cluster
- #api_key — Kafka::Protocol::AddPartitionsToTxnRequest
- #api_key — Kafka::Protocol::AlterConfigsRequest
- #api_key — Kafka::Protocol::ApiVersionsRequest
- #api_key — Kafka::Protocol::CreatePartitionsRequest
- #api_key — Kafka::Protocol::CreateTopicsRequest
- #api_key — Kafka::Protocol::DeleteTopicsRequest
- #api_key — Kafka::Protocol::DescribeConfigsRequest
- #api_key — Kafka::Protocol::DescribeGroupsRequest
- #api_key — Kafka::Protocol::EndTxnRequest
- #api_key — Kafka::Protocol::FetchRequest
- #api_key — Kafka::Protocol::FindCoordinatorRequest
- #api_key — Kafka::Protocol::HeartbeatRequest
- #api_key — Kafka::Protocol::InitProducerIDRequest
- #api_key — Kafka::Protocol::JoinGroupRequest
- #api_key — Kafka::Protocol::LeaveGroupRequest
- #api_key — Kafka::Protocol::ListGroupsRequest
- #api_key — Kafka::Protocol::ListOffsetRequest
- #api_key — Kafka::Protocol::MetadataRequest
- #api_key — Kafka::Protocol::OffsetCommitRequest
- #api_key — Kafka::Protocol::OffsetFetchRequest
- #api_key — Kafka::Protocol::ProduceRequest
- #api_key — Kafka::Protocol::SaslHandshakeRequest
- #api_key — Kafka::Protocol::SyncGroupRequest
- #api_name — Kafka::Protocol::ApiVersionsResponse::ApiInfo
- #api_version — Kafka::Protocol::AlterConfigsRequest
- #api_version — Kafka::Protocol::CreatePartitionsRequest
- #api_version — Kafka::Protocol::CreateTopicsRequest
- #api_version — Kafka::Protocol::DeleteTopicsRequest
- #api_version — Kafka::Protocol::DescribeConfigsRequest
- #api_version — Kafka::Protocol::DescribeGroupsRequest
- #api_version — Kafka::Protocol::FetchRequest
- #api_version — Kafka::Protocol::FindCoordinatorRequest
- #api_version — Kafka::Protocol::ListGroupsRequest
- #api_version — Kafka::Protocol::ListOffsetRequest
- #api_version — Kafka::Protocol::MetadataRequest
- #api_version — Kafka::Protocol::OffsetCommitRequest
- #api_version — Kafka::Protocol::OffsetFetchRequest
- #api_version — Kafka::Protocol::ProduceRequest
- #api_versions — Kafka::Broker
- #apis — Kafka::Client
- #apis — Kafka::Cluster
- #array — Kafka::Protocol::Decoder
- #assign — Kafka::Protocol::MemberAssignment
- #assign — Kafka::RoundRobinAssignmentStrategy
- #assign_partitions! — Kafka::Producer
- #assigned_to? — Kafka::ConsumerGroup
- #async_producer — Kafka::Client
- #attributes — Kafka::Protocol::RecordBatch
- #auth_message — Kafka::Sasl::Scram
- #authenticate! — Kafka::Sasl::Gssapi
- #authenticate! — Kafka::Sasl::OAuth
- #authenticate! — Kafka::Sasl::Plain
- #authenticate! — Kafka::Sasl::Scram
- #authenticate! — Kafka::SaslAuthenticator
- #begin_transaction — Kafka::Producer
- #begin_transaction — Kafka::TransactionManager
- #boolean — Kafka::Protocol::Decoder
- #brokers — Kafka::Client
- #buffer_bytesize — Kafka::Producer
- #buffer_for — Kafka::MessageBuffer
- #buffer_messages — Kafka::Producer
- #buffer_overflow — Kafka::AsyncProducer
- #buffer_overflow — Kafka::Datadog::ProducerSubscriber
- #buffer_overflow — Kafka::Datadog::AsyncProducerSubscriber
- #buffer_overflow — Kafka::Producer
- #buffer_overflow — Kafka::Statsd::ProducerSubscriber
- #buffer_overflow — Kafka::Statsd::AsyncProducerSubscriber
- #buffer_size — Kafka::Producer
- #build_connection — Kafka::ConnectionBuilder
- #bytes — Kafka::Protocol::Decoder
- #call — Kafka::TaggedFormatter
- #clear — Kafka::MessageBuffer
- #clear — Kafka::PendingMessageQueue
- #clear_buffer — Kafka::Producer
- #clear_current_offsets — Kafka::Consumer
- #clear_messages — Kafka::MessageBuffer
- #clear_offsets — Kafka::OffsetManager
- #clear_offsets_excluding — Kafka::OffsetManager
- #clear_resolved_offset — Kafka::OffsetManager
- #clear_tags! — Kafka::TaggedFormatter
- #clear_target_topics — Kafka::Cluster
- #client_key — Kafka::Sasl::Scram
- #client_proof — Kafka::Sasl::Scram
- #client_signature — Kafka::Sasl::Scram
- #close — Kafka::BrokerPool
- #close — Kafka::Client
- #close — Kafka::Connection
- #close — Kafka::SocketWithTimeout
- #close — Kafka::SSLSocketWithTimeout
- #close — Kafka::TransactionManager
- #closed? — Kafka::SocketWithTimeout
- #closed? — Kafka::SSLSocketWithTimeout
- #cluster_info — Kafka::Cluster
- #cluster_topics — Kafka::Consumer
- #codec_id — Kafka::GzipCodec
- #codec_id — Kafka::LZ4Codec
- #codec_id — Kafka::SnappyCodec
- #commit_offsets — Kafka::Broker
- #commit_offsets — Kafka::Consumer
- #commit_offsets — Kafka::ConsumerGroup
- #commit_offsets — Kafka::OffsetManager
- #commit_offsets_if_necessary — Kafka::OffsetManager
- #commit_threshold_reached? — Kafka::OffsetManager
- #commit_timeout_reached? — Kafka::OffsetManager
- #commit_transaction — Kafka::Producer
- #commit_transaction — Kafka::TransactionManager
- #committed_offset_for — Kafka::OffsetManager
- #committed_offsets — Kafka::OffsetManager
- #committing_transaction? — Kafka::TransactionStateMachine
- #complete_transaction — Kafka::TransactionManager
- #compress — Kafka::Compressor
- #compress — Kafka::GzipCodec
- #compress — Kafka::LZ4Codec
- #compress — Kafka::Protocol::ProduceRequest
- #compress — Kafka::SnappyCodec
- #compress_message_set — Kafka::Compressor
- #compress_record_batch — Kafka::Compressor
- #compressed? — Kafka::Protocol::Message
- #compressed? — Kafka::Protocol::RecordBatch
- #concat — Kafka::MessageBuffer
- #configure — Kafka::Fetcher
- #configured? — Kafka::Sasl::Gssapi
- #configured? — Kafka::Sasl::OAuth
- #configured? — Kafka::Sasl::Plain
- #configured? — Kafka::Sasl::Scram
- #connect — Kafka::BrokerPool
- #connect_to_broker — Kafka::Cluster
- #connected? — Kafka::Broker
- #connection — Kafka::Broker
- #consumer — Kafka::Client
- #consumer_loop — Kafka::Consumer
- #controller_broker — Kafka::Client
- #controller_broker — Kafka::Cluster
- #controller_broker — Kafka::Protocol::MetadataResponse
- #coordinator — Kafka::ConsumerGroup
- #correct_offsets — Kafka::Protocol::Message
- #create_partitions — Kafka::Broker
- #create_partitions_for — Kafka::Client
- #create_partitions_for — Kafka::Cluster
- #create_time — Kafka::FetchedMessage
- #create_topic — Kafka::Client
- #create_topic — Kafka::Cluster
- #create_topics — Kafka::Broker
- #current_tags — Kafka::TaggedFormatter
- #data? — Kafka::Fetcher
- #decompress — Kafka::GzipCodec
- #decompress — Kafka::LZ4Codec
- #decompress — Kafka::Protocol::Message
- #decompress — Kafka::SnappyCodec
- #delete_topic — Kafka::Client
- #delete_topic — Kafka::Cluster
- #delete_topics — Kafka::Broker
- #deliver_message — Kafka::Client
- #deliver_messages — Kafka::AsyncProducer
- #deliver_messages — Kafka::AsyncProducer::Worker
- #deliver_messages — Kafka::Datadog::ProducerSubscriber
- #deliver_messages — Kafka::Producer
- #deliver_messages — Kafka::Statsd::ProducerSubscriber
- #deliver_messages_with_retries — Kafka::Producer
- #describe_configs — Kafka::Broker
- #describe_group — Kafka::Client
- #describe_group — Kafka::Cluster
- #describe_groups — Kafka::Broker
- #describe_topic — Kafka::Client
- #describe_topic — Kafka::Cluster
- #digest — Kafka::Sasl::Scram
- #disconnect — Kafka::Broker
- #disconnect — Kafka::Cluster
- #drop_messages — Kafka::Datadog::AsyncProducerSubscriber
- #drop_messages — Kafka::Statsd::AsyncProducerSubscriber
- #each — Kafka::MessageBuffer
- #each — Kafka::PendingMessageQueue
- #each_batch — Kafka::Consumer
- #each_message — Kafka::Client
- #each_message — Kafka::Consumer
- #each_partition — Kafka::Protocol::ProduceResponse
- #emit — Kafka::Datadog::StatsdSubscriber
- #empty? — Kafka::FetchedBatch
- #empty? — Kafka::MessageBuffer
- #empty? — Kafka::PendingMessageQueue
- #empty_fetched_batch — Kafka::FetchedBatchGenerator
- #enabled? — Kafka::SaslAuthenticator
- #encode — Kafka::Protocol::AddPartitionsToTxnRequest
- #encode — Kafka::Protocol::AlterConfigsRequest
- #encode — Kafka::Protocol::ApiVersionsRequest
- #encode — Kafka::Protocol::ConsumerGroupProtocol
- #encode — Kafka::Protocol::CreatePartitionsRequest
- #encode — Kafka::Protocol::CreateTopicsRequest
- #encode — Kafka::Protocol::DeleteTopicsRequest
- #encode — Kafka::Protocol::DescribeConfigsRequest
- #encode — Kafka::Protocol::DescribeGroupsRequest
- #encode — Kafka::Protocol::EndTxnRequest
- #encode — Kafka::Protocol::FetchRequest
- #encode — Kafka::Protocol::FindCoordinatorRequest
- #encode — Kafka::Protocol::HeartbeatRequest
- #encode — Kafka::Protocol::InitProducerIDRequest
- #encode — Kafka::Protocol::JoinGroupRequest
- #encode — Kafka::Protocol::LeaveGroupRequest
- #encode — Kafka::Protocol::ListGroupsRequest
- #encode — Kafka::Protocol::ListOffsetRequest
- #encode — Kafka::Protocol::MemberAssignment
- #encode — Kafka::Protocol::Message
- #encode — Kafka::Protocol::MessageSet
- #encode — Kafka::Protocol::MetadataRequest
- #encode — Kafka::Protocol::OffsetCommitRequest
- #encode — Kafka::Protocol::OffsetFetchRequest
- #encode — Kafka::Protocol::ProduceRequest
- #encode — Kafka::Protocol::Record
- #encode — Kafka::Protocol::RecordBatch
- #encode — Kafka::Protocol::RequestMessage
- #encode — Kafka::Protocol::SaslHandshakeRequest
- #encode — Kafka::Protocol::SyncGroupRequest
- #encode_record_array — Kafka::Protocol::RecordBatch
- #encode_record_batch_body — Kafka::Protocol::RecordBatch
- #encode_with_crc — Kafka::Protocol::Message
- #encode_without_crc — Kafka::Protocol::Message
- #encoded_username — Kafka::Sasl::Scram
- #end_txn — Kafka::Broker
- #ends_at — Kafka::Pause
- #enqueue_message — Kafka::Datadog::AsyncProducerSubscriber
- #enqueue_message — Kafka::Statsd::AsyncProducerSubscriber
- #ensure_threads_running! — Kafka::AsyncProducer
- #eof? — Kafka::Protocol::Decoder
- #error? — Kafka::TransactionManager
- #error? — Kafka::TransactionStateMachine
- #execute — Kafka::FetchOperation
- #execute — Kafka::ProduceOperation
- #expired? — Kafka::Pause
- #extract_messages — Kafka::FetchedBatchGenerator
- #extract_records — Kafka::FetchedBatchGenerator
- #fetch_batch — Kafka::Datadog::ConsumerSubscriber
- #fetch_batch — Kafka::Statsd::ConsumerSubscriber
- #fetch_batches — Kafka::Consumer
- #fetch_batches — Kafka::Fetcher
- #fetch_cluster_info — Kafka::Cluster
- #fetch_from_partition — Kafka::FetchOperation
- #fetch_messages — Kafka::Broker
- #fetch_messages — Kafka::Client
- #fetch_metadata — Kafka::Broker
- #fetch_offsets — Kafka::Broker
- #fetch_offsets — Kafka::ConsumerGroup
- #fetch_resolved_offsets — Kafka::OffsetManager
- #filter_pending_topics — Kafka::FetchedOffsetResolver
- #final_message — Kafka::Sasl::Scram
- #final_message_without_proof — Kafka::Sasl::Scram
- #find_broker — Kafka::Protocol::MetadataResponse
- #find_coordinator — Kafka::Broker
- #find_leader_id — Kafka::Protocol::MetadataResponse
- #first_message — Kafka::Sasl::Scram
- #first_message_bare — Kafka::Sasl::Scram
- #first_offset — Kafka::FetchedBatch
- #flush — Kafka::TaggedLogger
- #force_transactional! — Kafka::TransactionManager
- #fulfill_relative_data — Kafka::Protocol::RecordBatch
- #generate — Kafka::FetchedBatchGenerator
- #get_coordinator — Kafka::Cluster
- #get_group_coordinator — Kafka::Cluster
- #get_leader — Kafka::Cluster
- #get_leader_id — Kafka::Cluster
- #get_transaction_coordinator — Kafka::Cluster
- #group_leader? — Kafka::ConsumerGroup
- #groups — Kafka::Client
- #h — Kafka::Sasl::Scram
- #handle_configure — Kafka::Fetcher
- #handle_reset — Kafka::Fetcher
- #handle_response — Kafka::ProduceOperation
- #handle_seek — Kafka::Fetcher
- #handle_stop — Kafka::Fetcher
- #handle_subscribe — Kafka::Fetcher
- #handshake_messages — Kafka::Sasl::Gssapi
- #has_topic? — Kafka::Client
- #headers — Kafka::FetchedMessage
- #headers — Kafka::Protocol::Message
- #heartbeat — Kafka::Broker
- #heartbeat — Kafka::ConsumerGroup
- #hi — Kafka::Sasl::Scram
- #hmac — Kafka::Sasl::Scram
- #idempotent? — Kafka::TransactionManager
- #ident — Kafka::Sasl::Gssapi
- #ident — Kafka::Sasl::OAuth
- #ident — Kafka::Sasl::Plain
- #ident — Kafka::Sasl::Scram
- #idle? — Kafka::Connection
- #in_state? — Kafka::TransactionStateMachine
- #in_transaction? — Kafka::TransactionManager
- #in_transaction? — Kafka::TransactionStateMachine
- #init_producer_id — Kafka::Broker
- #init_producer_id — Kafka::TransactionManager
- #init_transactions — Kafka::Producer
- #init_transactions — Kafka::TransactionManager
- #initial_client_response — Kafka::Sasl::OAuth
- #initialize_cluster — Kafka::Client
- #initialize_gssapi_context — Kafka::Sasl::Gssapi
- #inspect — Kafka::Protocol::ApiVersionsResponse::ApiInfo
- #instrument — Kafka::Instrumenter
- #instrument — Kafka::DecoratingInstrumenter
- #int16 — Kafka::Protocol::Decoder
- #int32 — Kafka::Protocol::Decoder
- #int64 — Kafka::Protocol::Decoder
- #int8 — Kafka::Protocol::Decoder
- #is_control_record — Kafka::FetchedMessage
- #is_control_record — Kafka::Protocol::Message
- #iterations — Kafka::Sasl::Scram
- #join — Kafka::ConsumerGroup
- #join_group — Kafka::Broker
- #join_group — Kafka::Consumer
- #join_group — Kafka::ConsumerGroup
- #join_group — Kafka::Datadog::ConsumerSubscriber
- #join_group — Kafka::Statsd::ConsumerSubscriber
- #key — Kafka::FetchedMessage
- #last_offset — Kafka::Protocol::RecordBatch
- #last_offset_for — Kafka::Client
- #last_offsets_for — Kafka::Client
- #leave — Kafka::ConsumerGroup
- #leave_group — Kafka::Broker
- #leave_group — Kafka::Datadog::ConsumerSubscriber
- #leave_group — Kafka::Statsd::ConsumerSubscriber
- #list_groups — Kafka::Broker
- #list_groups — Kafka::Cluster
- #list_offsets — Kafka::Broker
- #list_topics — Kafka::Cluster
- #load — Kafka::GzipCodec
- #load — Kafka::LZ4Codec
- #load — Kafka::SnappyCodec
- #load_gssapi — Kafka::Sasl::Gssapi
- #loop — Kafka::Datadog::ConsumerSubscriber
- #loop — Kafka::Datadog::FetcherSubscriber
- #loop — Kafka::Fetcher
- #loop — Kafka::Statsd::FetcherSubscriber
- #make_final_offsets_commit! — Kafka::Consumer
- #mark_as_processed — Kafka::OffsetManager
- #mark_as_stale! — Kafka::Cluster
- #mark_control_record — Kafka::Protocol::RecordBatch
- #mark_message_as_processed — Kafka::Consumer
- #member? — Kafka::ConsumerGroup
- #messages_for — Kafka::MessageBuffer
- #next_offset_for — Kafka::OffsetManager
- #next_sequence_for — Kafka::TransactionManager
- #nonce — Kafka::Sasl::Scram
- #normalize_seed_brokers — Kafka::Client
- #offset — Kafka::FetchedMessage
- #offset_for — Kafka::Protocol::ListOffsetResponse
- #offset_for — Kafka::Protocol::OffsetFetchResponse
- #offset_lag — Kafka::FetchedBatch
- #offsets_to_commit — Kafka::OffsetManager
- #offsets_to_recommit — Kafka::OffsetManager
- #open — Kafka::Connection
- #open? — Kafka::Connection
- #parse_response — Kafka::Sasl::Scram
- #partitions_for — Kafka::Client
- #partitions_for — Kafka::Cluster
- #partitions_for — Kafka::Protocol::MetadataResponse
- #pause — Kafka::Consumer
- #pause! — Kafka::Pause
- #pause_duration — Kafka::Pause
- #pause_for — Kafka::Consumer
- #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::TaggedFormatter
- #prettify_offsets — Kafka::OffsetManager
- #pretty_partitions — Kafka::Producer
- #process_batch — Kafka::Datadog::ConsumerSubscriber
- #process_batch — Kafka::Statsd::ConsumerSubscriber
- #process_message — Kafka::Datadog::ConsumerSubscriber
- #process_message — Kafka::Statsd::ConsumerSubscriber
- #produce — Kafka::AsyncProducer
- #produce — Kafka::AsyncProducer::Worker
- #produce — Kafka::Broker
- #produce — Kafka::Producer
- #produce_message — Kafka::Datadog::ProducerSubscriber
- #produce_message — Kafka::Statsd::ProducerSubscriber
- #producer — Kafka::Client
- #push_tags — Kafka::TaggedFormatter
- #random_broker — Kafka::Cluster
- #read — Kafka::Protocol::Decoder
- #read — Kafka::SocketWithTimeout
- #read — Kafka::SSLSocketWithTimeout
- #read_response — Kafka::Connection
- #ready? — Kafka::TransactionStateMachine
- #recommit_timeout_reached? — Kafka::OffsetManager
- #refresh_metadata! — Kafka::Cluster
- #refresh_metadata_if_necessary! — Kafka::Cluster
- #replace — Kafka::PendingMessageQueue
- #request — Kafka::Datadog::ConnectionSubscriber
- #request — Kafka::Statsd::ConnectionSubscriber
- #requires_acks? — Kafka::Protocol::ProduceRequest
- #reset — Kafka::Fetcher
- #reset! — Kafka::Pause
- #resolve! — Kafka::FetchedOffsetResolver
- #resolve_offset — Kafka::Cluster
- #resolve_offset — Kafka::OffsetManager
- #resolve_offsets — Kafka::Cluster
- #response_class — Kafka::Protocol::AddPartitionsToTxnRequest
- #response_class — Kafka::Protocol::AlterConfigsRequest
- #response_class — Kafka::Protocol::ApiVersionsRequest
- #response_class — Kafka::Protocol::CreatePartitionsRequest
- #response_class — Kafka::Protocol::CreateTopicsRequest
- #response_class — Kafka::Protocol::DeleteTopicsRequest
- #response_class — Kafka::Protocol::DescribeConfigsRequest
- #response_class — Kafka::Protocol::DescribeGroupsRequest
- #response_class — Kafka::Protocol::EndTxnRequest
- #response_class — Kafka::Protocol::FetchRequest
- #response_class — Kafka::Protocol::FindCoordinatorRequest
- #response_class — Kafka::Protocol::HeartbeatRequest
- #response_class — Kafka::Protocol::InitProducerIDRequest
- #response_class — Kafka::Protocol::JoinGroupRequest
- #response_class — Kafka::Protocol::LeaveGroupRequest
- #response_class — Kafka::Protocol::ListGroupsRequest
- #response_class — Kafka::Protocol::ListOffsetRequest
- #response_class — Kafka::Protocol::MetadataRequest
- #response_class — Kafka::Protocol::OffsetCommitRequest
- #response_class — Kafka::Protocol::OffsetFetchRequest
- #response_class — Kafka::Protocol::ProduceRequest
- #response_class — Kafka::Protocol::SaslHandshakeRequest
- #response_class — Kafka::Protocol::SyncGroupRequest
- #resume — Kafka::Consumer
- #resume! — Kafka::Pause
- #resume_paused_partitions! — Kafka::Consumer
- #rnonce — Kafka::Sasl::Scram
- #run — Kafka::AsyncProducer::Timer
- #run — Kafka::AsyncProducer::Worker
- #running? — Kafka::Consumer
- #safe_str — Kafka::Sasl::Scram
- #salt — Kafka::Sasl::Scram
- #salted_password — Kafka::Sasl::Scram
- #seconds_since — Kafka::OffsetManager
- #seconds_since_last_commit — Kafka::OffsetManager
- #seek — Kafka::Consumer
- #seek — Kafka::Fetcher
- #seek_to — Kafka::OffsetManager
- #seek_to_default — Kafka::OffsetManager
- #seek_to_next — Kafka::Consumer
- #select_with_timeout — Kafka::SSLSocketWithTimeout
- #send_and_receive_sasl_token — Kafka::Sasl::Gssapi
- #send_buffered_messages — Kafka::ProduceOperation
- #send_heartbeat — Kafka::Consumer
- #send_heartbeat_if_necessary — Kafka::Consumer
- #send_request — Kafka::Broker
- #send_request — Kafka::Connection
- #server_data — Kafka::Sasl::Scram
- #server_key — Kafka::Sasl::Scram
- #server_signature — Kafka::Sasl::Scram
- #set_default_offset — Kafka::OffsetManager
- #set_encoding — Kafka::SocketWithTimeout
- #set_encoding — Kafka::SSLSocketWithTimeout
- #shutdown — Kafka::AsyncProducer
- #shutdown — Kafka::Producer
- #shutting_down? — Kafka::Consumer
- #size — Kafka::Protocol::MessageSet
- #size — Kafka::Protocol::RecordBatch
- #start — Kafka::Fetcher
- #step — Kafka::Fetcher
- #stop — Kafka::Consumer
- #stop — Kafka::Fetcher
- #stored_key — Kafka::Sasl::Scram
- #string — Kafka::Protocol::Decoder
- #subscribe — Kafka::Consumer
- #subscribe — Kafka::ConsumerGroup
- #subscribe — Kafka::Fetcher
- #subscribe_to_topic — Kafka::Consumer
- #subscribed_partitions — Kafka::ConsumerGroup
- #supports_api? — Kafka::Client
- #supports_api? — Kafka::Cluster
- #sync_group — Kafka::Broker
- #sync_group — Kafka::Datadog::ConsumerSubscriber
- #sync_group — Kafka::Statsd::ConsumerSubscriber
- #synchronize — Kafka::ConsumerGroup
- #tagged — Kafka::TaggedFormatter
- #tagged — Kafka::TaggedLogger
- #tags_text — Kafka::TaggedFormatter
- #threshold_reached? — Kafka::AsyncProducer::Worker
- #to_h — Kafka::MessageBuffer
- #to_s — Kafka::Broker
- #to_s — Kafka::BrokerInfo
- #to_s — Kafka::Connection
- #to_s — Kafka::ConsumerGroup
- #to_s — Kafka::Producer
- #to_s — Kafka::Protocol::ApiVersionsResponse::ApiInfo
- #token_extensions — Kafka::Sasl::OAuth
- #topic_error — Kafka::Datadog::ProducerSubscriber
- #topic_error — Kafka::Statsd::ProducerSubscriber
- #topics — Kafka::Client
- #topics — Kafka::Cluster
- #transaction — Kafka::Producer
- #transaction_coordinator — Kafka::TransactionManager
- #transactional? — Kafka::TransactionManager
- #transition_to! — Kafka::TransactionStateMachine
- #trigger — Kafka::Heartbeat
- #trigger! — Kafka::Heartbeat
- #trigger_heartbeat — Kafka::Consumer
- #trigger_heartbeat! — Kafka::Consumer
- #uninitialized? — Kafka::TransactionStateMachine
- #unknown_last_offset? — Kafka::FetchedBatch
- #update_sequence_for — Kafka::TransactionManager
- #value — Kafka::FetchedMessage
- #varint — Kafka::Protocol::Decoder
- #varint_array — Kafka::Protocol::Decoder
- #varint_bytes — Kafka::Protocol::Decoder
- #varint_string — Kafka::Protocol::Decoder
- #version_supported? — Kafka::Protocol::ApiVersionsResponse::ApiInfo
- #wait_for_response — Kafka::Connection
- #write — Kafka::MessageBuffer
- #write — Kafka::PendingMessageQueue
- #write — Kafka::Protocol::Encoder
- #write — Kafka::SocketWithTimeout
- #write — Kafka::SSLSocketWithTimeout
- #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_request — Kafka::Connection
- #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
- #xor — Kafka::Sasl::Scram