lib/ruby-kafka.rb
# frozen_string_literal: true # Needed because the gem is registered as `ruby-kafka`. require "kafka"
Source Files
- lib/kafka.rb
- lib/kafka/async_producer.rb
- lib/kafka/broker.rb
- lib/kafka/broker_pool.rb
- lib/kafka/broker_uri.rb
- lib/kafka/client.rb
- lib/kafka/cluster.rb
- lib/kafka/compression.rb
- lib/kafka/compressor.rb
- lib/kafka/connection.rb
- lib/kafka/connection_builder.rb
- lib/kafka/consumer.rb
- lib/kafka/consumer_group.rb
- lib/kafka/datadog.rb
- lib/kafka/fetch_operation.rb
- lib/kafka/fetched_batch.rb
- lib/kafka/fetched_message.rb
- lib/kafka/fetcher.rb
- lib/kafka/gzip_codec.rb
- lib/kafka/heartbeat.rb
- lib/kafka/instrumenter.rb
- lib/kafka/lz4_codec.rb
- lib/kafka/message_buffer.rb
- lib/kafka/offset_manager.rb
- lib/kafka/partitioner.rb
- lib/kafka/pause.rb
- lib/kafka/pending_message.rb
- lib/kafka/pending_message_queue.rb
- lib/kafka/produce_operation.rb
- lib/kafka/producer.rb
- lib/kafka/protocol.rb
- lib/kafka/protocol/alter_configs_request.rb
- lib/kafka/protocol/alter_configs_response.rb
- lib/kafka/protocol/api_versions_request.rb
- lib/kafka/protocol/api_versions_response.rb
- lib/kafka/protocol/consumer_group_protocol.rb
- lib/kafka/protocol/create_partitions_request.rb
- lib/kafka/protocol/create_partitions_response.rb
- lib/kafka/protocol/create_topics_request.rb
- lib/kafka/protocol/create_topics_response.rb
- lib/kafka/protocol/decoder.rb
- lib/kafka/protocol/delete_topics_request.rb
- lib/kafka/protocol/delete_topics_response.rb
- lib/kafka/protocol/describe_configs_request.rb
- lib/kafka/protocol/describe_configs_response.rb
- lib/kafka/protocol/encoder.rb
- lib/kafka/protocol/fetch_request.rb
- lib/kafka/protocol/fetch_response.rb
- lib/kafka/protocol/group_coordinator_request.rb
- lib/kafka/protocol/group_coordinator_response.rb
- lib/kafka/protocol/heartbeat_request.rb
- lib/kafka/protocol/heartbeat_response.rb
- lib/kafka/protocol/join_group_request.rb
- lib/kafka/protocol/join_group_response.rb
- lib/kafka/protocol/leave_group_request.rb
- lib/kafka/protocol/leave_group_response.rb
- lib/kafka/protocol/list_offset_request.rb
- lib/kafka/protocol/list_offset_response.rb
- lib/kafka/protocol/member_assignment.rb
- lib/kafka/protocol/message.rb
- lib/kafka/protocol/message_set.rb
- lib/kafka/protocol/metadata_request.rb
- lib/kafka/protocol/metadata_response.rb
- lib/kafka/protocol/offset_commit_request.rb
- lib/kafka/protocol/offset_commit_response.rb
- lib/kafka/protocol/offset_fetch_request.rb
- lib/kafka/protocol/offset_fetch_response.rb
- lib/kafka/protocol/produce_request.rb
- lib/kafka/protocol/produce_response.rb
- lib/kafka/protocol/request_message.rb
- lib/kafka/protocol/sasl_handshake_request.rb
- lib/kafka/protocol/sasl_handshake_response.rb
- lib/kafka/protocol/sync_group_request.rb
- lib/kafka/protocol/sync_group_response.rb
- lib/kafka/round_robin_assignment_strategy.rb
- lib/kafka/sasl/gssapi.rb
- lib/kafka/sasl/plain.rb
- lib/kafka/sasl/scram.rb
- lib/kafka/sasl_authenticator.rb
- lib/kafka/snappy_codec.rb
- lib/kafka/socket_with_timeout.rb
- lib/kafka/ssl_context.rb
- lib/kafka/ssl_socket_with_timeout.rb
- lib/kafka/statsd.rb
- lib/kafka/version.rb
- lib/ruby-kafka.rb