Module: Kafka

Defined in:

lib/kafka/broker_info.rb,
lib/kafka/pause.rb,
lib/kafka/broker.rb,
lib/kafka/client.rb,
lib/kafka/statsd.rb,
lib/kafka/cluster.rb,
lib/kafka/datadog.rb,
lib/kafka/fetcher.rb,
lib/kafka/version.rb,
lib/kafka/consumer.rb,
lib/kafka/producer.rb,
lib/kafka/protocol.rb,
lib/kafka/heartbeat.rb,
lib/kafka/lz4_codec.rb,
lib/kafka/broker_uri.rb,
lib/kafka/compressor.rb,
lib/kafka/connection.rb,
lib/kafka/gzip_codec.rb,
lib/kafka/sasl/oauth.rb,
lib/kafka/sasl/plain.rb,
lib/kafka/sasl/scram.rb,
lib/kafka/broker_pool.rb,
lib/kafka/compression.rb,
lib/kafka/partitioner.rb,
lib/kafka/sasl/gssapi.rb,
lib/kafka/ssl_context.rb,
lib/kafka/instrumenter.rb,
lib/kafka/snappy_codec.rb,
lib/kafka/fetched_batch.rb,
lib/kafka/tagged_logger.rb,
lib/kafka/async_producer.rb,
lib/kafka/consumer_group.rb,
lib/kafka/message_buffer.rb,
lib/kafka/offset_manager.rb,
lib/kafka/fetch_operation.rb,
lib/kafka/fetched_message.rb,
lib/kafka/pending_message.rb,
lib/kafka/protocol/record.rb,
lib/kafka/protocol/decoder.rb,
lib/kafka/protocol/encoder.rb,
lib/kafka/protocol/message.rb,
lib/kafka/produce_operation.rb,
lib/kafka/connection_builder.rb,
lib/kafka/sasl_authenticator.rb,
lib/kafka/socket_with_timeout.rb,
lib/kafka/transaction_manager.rb,
lib/kafka/protocol/message_set.rb,
lib/kafka/pending_message_queue.rb,
lib/kafka/protocol/record_batch.rb,
lib/kafka/protocol/fetch_request.rb,
lib/kafka/fetched_batch_generator.rb,
lib/kafka/fetched_offset_resolver.rb,
lib/kafka/protocol/fetch_response.rb,
lib/kafka/ssl_socket_with_timeout.rb,
lib/kafka/protocol/end_txn_request.rb,
lib/kafka/protocol/produce_request.rb,
lib/kafka/protocol/request_message.rb,
lib/kafka/protocol/end_txn_response.rb,
lib/kafka/protocol/metadata_request.rb,
lib/kafka/protocol/produce_response.rb,
lib/kafka/transaction_state_machine.rb,
lib/kafka/protocol/heartbeat_request.rb,
lib/kafka/protocol/member_assignment.rb,
lib/kafka/protocol/metadata_response.rb,
lib/kafka/protocol/heartbeat_response.rb,
lib/kafka/protocol/join_group_request.rb,
lib/kafka/protocol/sync_group_request.rb,
lib/kafka/protocol/join_group_response.rb,
lib/kafka/protocol/leave_group_request.rb,
lib/kafka/protocol/list_groups_request.rb,
lib/kafka/protocol/list_offset_request.rb,
lib/kafka/protocol/sync_group_response.rb,
lib/kafka/protocol/api_versions_request.rb,
lib/kafka/protocol/leave_group_response.rb,
lib/kafka/protocol/list_groups_response.rb,
lib/kafka/protocol/list_offset_response.rb,
lib/kafka/protocol/offset_fetch_request.rb,
lib/kafka/protocol/alter_configs_request.rb,
lib/kafka/protocol/api_versions_response.rb,
lib/kafka/protocol/create_topics_request.rb,
lib/kafka/protocol/delete_topics_request.rb,
lib/kafka/protocol/offset_commit_request.rb,
lib/kafka/protocol/offset_fetch_response.rb,
lib/kafka/protocol/alter_configs_response.rb,
lib/kafka/protocol/create_topics_response.rb,
lib/kafka/protocol/delete_topics_response.rb,
lib/kafka/protocol/offset_commit_response.rb,
lib/kafka/protocol/sasl_handshake_request.rb,
lib/kafka/round_robin_assignment_strategy.rb,
lib/kafka/protocol/consumer_group_protocol.rb,
lib/kafka/protocol/describe_groups_request.rb,
lib/kafka/protocol/sasl_handshake_response.rb,
lib/kafka/protocol/describe_configs_request.rb,
lib/kafka/protocol/describe_groups_response.rb,
lib/kafka/protocol/find_coordinator_request.rb,
lib/kafka/protocol/init_producer_id_request.rb,
lib/kafka/protocol/create_partitions_request.rb,
lib/kafka/protocol/describe_configs_response.rb,
lib/kafka/protocol/find_coordinator_response.rb,
lib/kafka/protocol/init_producer_id_response.rb,
lib/kafka/protocol/create_partitions_response.rb,
lib/kafka/protocol/add_partitions_to_txn_request.rb,
lib/kafka/protocol/add_partitions_to_txn_response.rb

Overview

Basic implementation of a tagged logger that matches the API of ActiveSupport::TaggedLogging.

Defined Under Namespace

Modules: BrokerUri, Compression, Datadog, Protocol, Sasl, SslContext, Statsd, TaggedFormatter, TaggedLogger Classes: AsyncProducer, Broker, BrokerInfo, BrokerPool, Client, Cluster, Compressor, Connection, ConnectionBuilder, Consumer, ConsumerGroup, DecoratingInstrumenter, FetchOperation, FetchedBatch, FetchedBatchGenerator, FetchedMessage, FetchedOffsetResolver, Fetcher, GzipCodec, Heartbeat, Instrumenter, LZ4Codec, MessageBuffer, OffsetManager, Partitioner, Pause, PendingMessage, PendingMessageQueue, ProduceOperation, Producer, RoundRobinAssignmentStrategy, SSLSocketWithTimeout, SaslAuthenticator, SnappyCodec, SocketWithTimeout, TransactionManager, TransactionStateMachine

Constant Summary

VERSION =

"0.7.6"