Module: Kafka

Defined in:

lib/kafka.rb,
lib/kafka/broker.rb,
lib/kafka/client.rb,
lib/kafka/cluster.rb,
lib/kafka/version.rb,
lib/kafka/producer.rb,
lib/kafka/protocol.rb,
lib/kafka/connection.rb,
lib/kafka/gzip_codec.rb,
lib/kafka/broker_pool.rb,
lib/kafka/compression.rb,
lib/kafka/partitioner.rb,
lib/kafka/snappy_codec.rb,
lib/kafka/async_producer.rb,
lib/kafka/message_buffer.rb,
lib/kafka/fetch_operation.rb,
lib/kafka/fetched_message.rb,
lib/kafka/instrumentation.rb,
lib/kafka/pending_message.rb,
lib/kafka/protocol/decoder.rb,
lib/kafka/protocol/encoder.rb,
lib/kafka/protocol/message.rb,
lib/kafka/produce_operation.rb,
lib/kafka/socket_with_timeout.rb,
lib/kafka/protocol/message_set.rb,
lib/kafka/pending_message_queue.rb,
lib/kafka/protocol/fetch_request.rb,
lib/kafka/protocol/fetch_response.rb,
lib/kafka/protocol/produce_request.rb,
lib/kafka/protocol/request_message.rb,
lib/kafka/protocol/produce_response.rb,
lib/kafka/protocol/metadata_response.rb,
lib/kafka/protocol/list_offset_request.rb,
lib/kafka/protocol/list_offset_response.rb,
lib/kafka/protocol/topic_metadata_request.rb

Defined Under Namespace

Modules: Compression, Protocol Classes: AsyncProducer, Broker, BrokerNotAvailable, BrokerPool, BufferOverflow, Client, Cluster, Connection, ConnectionError, CorruptMessage, DeliveryFailed, Error, FetchOperation, FetchedMessage, GzipCodec, InvalidMessageSize, InvalidRequiredAcks, InvalidTopic, LeaderNotAvailable, MessageBuffer, MessageSizeTooLarge, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, NullInstrumentation, OffsetMetadataTooLarge, OffsetOutOfRange, Partitioner, PendingMessage, PendingMessageQueue, ProduceOperation, Producer, ProtocolError, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, SnappyCodec, SocketWithTimeout, UnknownError, UnknownTopicOrPartition

Constant Summary

VERSION =

"0.1.7"

Instrumentation =

NullInstrumentation

Class Method Summary

• .new(**options) ⇒ Client

  Initializes a new Kafka client.

Class Method Details

.new(**options) ⇒ Client

Initializes a new Kafka client.

Returns:

• (Client)

See Also:

• Kafka::Client#initialize

# File 'lib/kafka.rb', line 108

def self.new(**options)
  Client.new(**options)
end