Module: Kafka

Defined in:
lib/kafka.rb,
lib/kafka/broker.rb,
lib/kafka/client.rb,
lib/kafka/statsd.rb,
lib/kafka/cluster.rb,
lib/kafka/datadog.rb,
lib/kafka/version.rb,
lib/kafka/consumer.rb,
lib/kafka/producer.rb,
lib/kafka/protocol.rb,
lib/kafka/heartbeat.rb,
lib/kafka/compressor.rb,
lib/kafka/connection.rb,
lib/kafka/gzip_codec.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/instrumenter.rb,
lib/kafka/snappy_codec.rb,
lib/kafka/fetched_batch.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/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/protocol/message_set.rb,
lib/kafka/pending_message_queue.rb,
lib/kafka/protocol/fetch_request.rb,
lib/kafka/protocol/fetch_response.rb,
lib/kafka/ssl_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/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_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_offset_response.rb,
lib/kafka/protocol/offset_fetch_request.rb,
lib/kafka/protocol/api_versions_response.rb,
lib/kafka/protocol/create_topics_request.rb,
lib/kafka/protocol/offset_commit_request.rb,
lib/kafka/protocol/offset_fetch_response.rb,
lib/kafka/protocol/create_topics_response.rb,
lib/kafka/protocol/offset_commit_response.rb,
lib/kafka/protocol/sasl_handshake_request.rb,
lib/kafka/protocol/topic_metadata_request.rb,
lib/kafka/round_robin_assignment_strategy.rb,
lib/kafka/protocol/consumer_group_protocol.rb,
lib/kafka/protocol/sasl_handshake_response.rb,
lib/kafka/protocol/group_coordinator_request.rb,
lib/kafka/protocol/group_coordinator_response.rb

Defined Under Namespace

Modules: Compression, Datadog, Protocol, Sasl, Statsd Classes: AsyncProducer, Broker, BrokerNotAvailable, BrokerPool, BufferOverflow, Client, Cluster, ClusterAuthorizationCode, Compressor, Connection, ConnectionBuilder, ConnectionError, Consumer, ConsumerGroup, CorruptMessage, DecoratingInstrumenter, DeliveryFailed, Error, FailedScramAuthentication, FetchError, FetchOperation, FetchedBatch, FetchedMessage, GroupAuthorizationCode, GroupCoordinatorNotAvailable, GzipCodec, Heartbeat, HeartbeatError, IdleConnection, IllegalGeneration, Instrumenter, InvalidCommitOffsetSize, InvalidConfig, InvalidMessageSize, InvalidPartitions, InvalidReplicaAssignment, InvalidReplicationFactor, InvalidRequest, InvalidRequiredAcks, InvalidSaslState, InvalidSessionTimeout, InvalidTimestamp, InvalidTopic, LeaderNotAvailable, MessageBuffer, MessageSizeTooLarge, MessageTooLargeToRead, NoPartitionsToFetchFrom, NoSuchBroker, NotController, NotCoordinatorForGroup, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, OffsetCommitError, OffsetManager, OffsetMetadataTooLarge, OffsetOutOfRange, Partitioner, PendingMessage, PendingMessageQueue, ProcessingError, ProduceOperation, Producer, ProtocolError, RebalanceInProgress, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, RoundRobinAssignmentStrategy, SSLSocketWithTimeout, SaslAuthenticator, SaslScramError, SnappyCodec, SocketWithTimeout, TopicAlreadyExists, TopicAuthorizationCode, UnknownError, UnknownMemberId, UnknownTopicOrPartition, UnsupportedSaslMechanism, UnsupportedVersion

Constant Summary collapse

VERSION =
"0.5.1"

Class Method Summary collapse

Class Method Details

.new(**options) ⇒ Client

Initializes a new Kafka client.

Returns:

See Also:


246
247
248
# File 'lib/kafka.rb', line 246

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