Module: Kafka

Defined in:
lib/kafka.rb,
lib/kafka/client.rb,
lib/kafka/broker.rb,
lib/kafka/cluster.rb,
lib/kafka/version.rb,
lib/kafka/consumer.rb,
lib/kafka/producer.rb,
lib/kafka/protocol.rb,
lib/kafka/heartbeat.rb,
lib/kafka/connection.rb,
lib/kafka/gzip_codec.rb,
lib/kafka/compressor.rb,
lib/kafka/compression.rb,
lib/kafka/broker_pool.rb,
lib/kafka/partitioner.rb,
lib/kafka/snappy_codec.rb,
lib/kafka/instrumenter.rb,
lib/kafka/fetched_batch.rb,
lib/kafka/consumer_group.rb,
lib/kafka/message_buffer.rb,
lib/kafka/async_producer.rb,
lib/kafka/offset_manager.rb,
lib/kafka/pending_message.rb,
lib/kafka/fetch_operation.rb,
lib/kafka/fetched_message.rb,
lib/kafka/protocol/encoder.rb,
lib/kafka/protocol/decoder.rb,
lib/kafka/protocol/message.rb,
lib/kafka/produce_operation.rb,
lib/kafka/connection_builder.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/ssl_socket_with_timeout.rb,
lib/kafka/protocol/fetch_response.rb,
lib/kafka/protocol/request_message.rb,
lib/kafka/protocol/produce_request.rb,
lib/kafka/protocol/produce_response.rb,
lib/kafka/protocol/heartbeat_request.rb,
lib/kafka/protocol/metadata_response.rb,
lib/kafka/protocol/member_assignment.rb,
lib/kafka/protocol/heartbeat_response.rb,
lib/kafka/protocol/sync_group_request.rb,
lib/kafka/protocol/join_group_request.rb,
lib/kafka/protocol/leave_group_request.rb,
lib/kafka/protocol/sync_group_response.rb,
lib/kafka/protocol/list_offset_request.rb,
lib/kafka/protocol/join_group_response.rb,
lib/kafka/protocol/list_offset_response.rb,
lib/kafka/protocol/leave_group_response.rb,
lib/kafka/protocol/offset_fetch_request.rb,
lib/kafka/protocol/offset_commit_request.rb,
lib/kafka/protocol/offset_fetch_response.rb,
lib/kafka/round_robin_assignment_strategy.rb,
lib/kafka/protocol/offset_commit_response.rb,
lib/kafka/protocol/topic_metadata_request.rb,
lib/kafka/protocol/consumer_group_protocol.rb,
lib/kafka/protocol/group_coordinator_request.rb,
lib/kafka/protocol/group_coordinator_response.rb

Defined Under Namespace

Modules: Compression, Protocol Classes: AsyncProducer, Broker, BrokerNotAvailable, BrokerPool, BufferOverflow, Client, Cluster, Compressor, Connection, ConnectionBuilder, ConnectionError, Consumer, ConsumerGroup, CorruptMessage, DeliveryFailed, Error, FetchError, FetchOperation, FetchedBatch, FetchedMessage, GroupCoordinatorNotAvailable, GzipCodec, Heartbeat, HeartbeatError, IllegalGeneration, Instrumenter, InvalidMessageSize, InvalidRequiredAcks, InvalidSessionTimeout, InvalidTopic, LeaderNotAvailable, MessageBuffer, MessageSizeTooLarge, NotCoordinatorForGroup, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, OffsetCommitError, OffsetManager, OffsetMetadataTooLarge, OffsetOutOfRange, Partitioner, PendingMessage, PendingMessageQueue, ProduceOperation, Producer, ProtocolError, RebalanceInProgress, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, RoundRobinAssignmentStrategy, SSLSocketWithTimeout, SnappyCodec, SocketWithTimeout, UnknownError, UnknownMemberId, UnknownTopicOrPartition

Constant Summary collapse

VERSION =
"0.3.4"

Class Method Summary collapse

Class Method Details

.new(**options) ⇒ Client

Initializes a new Kafka client.

Returns:

See Also:


135
136
137
# File 'lib/kafka.rb', line 135

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