Module: Kafka

Defined in:

lib/kafka.rb,
lib/kafka/broker.rb,
lib/kafka/client.rb,
lib/kafka/version.rb,
lib/kafka/producer.rb,
lib/kafka/protocol.rb,
lib/kafka/connection.rb,
lib/kafka/broker_pool.rb,
lib/kafka/partitioner.rb,
lib/kafka/transmission.rb,
lib/kafka/message_buffer.rb,
lib/kafka/protocol/decoder.rb,
lib/kafka/protocol/encoder.rb,
lib/kafka/protocol/message.rb,
lib/kafka/socket_with_timeout.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/topic_metadata_request.rb

Defined Under Namespace

Modules: Protocol Classes: Broker, BrokerNotAvailable, BrokerPool, BufferOverflow, Client, Connection, ConnectionError, CorruptMessage, Error, FailedToSendMessages, InvalidMessageSize, InvalidRequiredAcks, InvalidTopic, LeaderNotAvailable, MessageBuffer, MessageSizeTooLarge, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, OffsetMetadataTooLarge, OffsetOutOfRange, Partitioner, Producer, ProtocolError, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, SocketWithTimeout, Transmission, UnknownError, UnknownTopicOrPartition

Constant Summary

VERSION =

"0.1.1"

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