module Kafka
def self.new(seed_brokers = nil, **options)
-
(Client)
-
Other tags:
- See: Client#initialize -
def self.new(seed_brokers = nil, **options) # We allow `seed_brokers` to be passed in either as a positional _or_ as a # keyword argument. if seed_brokers.nil? Client.new(**options) else Client.new(seed_brokers: seed_brokers, **options) end end
Modules
Classes
- Kafka::AsyncProducer
- Kafka::Broker
- Kafka::BrokerNotAvailable
- Kafka::BrokerPool
- Kafka::BufferOverflow
- Kafka::Client
- Kafka::Cluster
- Kafka::ClusterAuthorizationFailed
- Kafka::Compressor
- Kafka::Connection
- Kafka::ConnectionBuilder
- Kafka::ConnectionError
- Kafka::Consumer
- Kafka::ConsumerGroup
- Kafka::CorruptMessage
- Kafka::DecoratingInstrumenter
- Kafka::DeliveryFailed
- Kafka::Error
- Kafka::FailedScramAuthentication
- Kafka::FetchError
- Kafka::FetchOperation
- Kafka::FetchedBatch
- Kafka::FetchedMessage
- Kafka::Fetcher
- Kafka::GroupAuthorizationFailed
- Kafka::GroupCoordinatorNotAvailable
- Kafka::GzipCodec
- Kafka::Heartbeat
- Kafka::HeartbeatError
- Kafka::IdleConnection
- Kafka::IllegalGeneration
- Kafka::Instrumenter
- Kafka::InvalidCommitOffsetSize
- Kafka::InvalidConfig
- Kafka::InvalidMessageSize
- Kafka::InvalidPartitions
- Kafka::InvalidReplicaAssignment
- Kafka::InvalidReplicationFactor
- Kafka::InvalidRequest
- Kafka::InvalidRequiredAcks
- Kafka::InvalidSaslState
- Kafka::InvalidSessionTimeout
- Kafka::InvalidTimestamp
- Kafka::InvalidTopic
- Kafka::LZ4Codec
- Kafka::LeaderNotAvailable
- Kafka::MessageBuffer
- Kafka::MessageSizeTooLarge
- Kafka::MessageTooLargeToRead
- Kafka::NoPartitionsToFetchFrom
- Kafka::NoSuchBroker
- Kafka::NotController
- Kafka::NotCoordinatorForGroup
- Kafka::NotEnoughReplicas
- Kafka::NotEnoughReplicasAfterAppend
- Kafka::NotLeaderForPartition
- Kafka::OffsetCommitError
- Kafka::OffsetManager
- Kafka::OffsetMetadataTooLarge
- Kafka::OffsetOutOfRange
- Kafka::Partitioner
- Kafka::Pause
- Kafka::PendingMessage
- Kafka::PendingMessageQueue
- Kafka::ProcessingError
- Kafka::ProduceOperation
- Kafka::Producer
- Kafka::ProtocolError
- Kafka::RebalanceInProgress
- Kafka::RecordListTooLarge
- Kafka::ReplicaNotAvailable
- Kafka::RequestTimedOut
- Kafka::RoundRobinAssignmentStrategy
- Kafka::SSLSocketWithTimeout
- Kafka::SaslAuthenticator
- Kafka::SaslScramError
- Kafka::SnappyCodec
- Kafka::SocketWithTimeout
- Kafka::TopicAlreadyExists
- Kafka::TopicAuthorizationFailed
- Kafka::UnknownError
- Kafka::UnknownMemberId
- Kafka::UnknownTopicOrPartition
- Kafka::UnsupportedSaslMechanism
- Kafka::UnsupportedVersion
Class Methods
Defined in
- lib/kafka.rb
- lib/kafka/async_producer.rb
- lib/kafka/broker.rb
- lib/kafka/broker_pool.rb
- lib/kafka/broker_uri.rb
- lib/kafka/client.rb
- lib/kafka/cluster.rb
- lib/kafka/compression.rb
- lib/kafka/compressor.rb
- lib/kafka/connection.rb
- lib/kafka/connection_builder.rb
- lib/kafka/consumer.rb
- lib/kafka/consumer_group.rb
- lib/kafka/datadog.rb
- lib/kafka/fetch_operation.rb
- lib/kafka/fetched_batch.rb
- lib/kafka/fetched_message.rb
- lib/kafka/fetcher.rb
- lib/kafka/gzip_codec.rb
- lib/kafka/heartbeat.rb
- lib/kafka/instrumenter.rb
- lib/kafka/lz4_codec.rb
- lib/kafka/message_buffer.rb
- lib/kafka/offset_manager.rb
- lib/kafka/partitioner.rb
- lib/kafka/pause.rb
- lib/kafka/pending_message.rb
- lib/kafka/pending_message_queue.rb
- lib/kafka/produce_operation.rb
- lib/kafka/producer.rb
- lib/kafka/protocol.rb
- lib/kafka/protocol/alter_configs_request.rb
- lib/kafka/protocol/alter_configs_response.rb
- lib/kafka/protocol/api_versions_request.rb
- lib/kafka/protocol/api_versions_response.rb
- lib/kafka/protocol/consumer_group_protocol.rb
- lib/kafka/protocol/create_partitions_request.rb
- lib/kafka/protocol/create_partitions_response.rb
- lib/kafka/protocol/create_topics_request.rb
- lib/kafka/protocol/create_topics_response.rb
- lib/kafka/protocol/decoder.rb
- lib/kafka/protocol/delete_topics_request.rb
- lib/kafka/protocol/delete_topics_response.rb
- lib/kafka/protocol/describe_configs_request.rb
- lib/kafka/protocol/describe_configs_response.rb
- lib/kafka/protocol/encoder.rb
- lib/kafka/protocol/fetch_request.rb
- lib/kafka/protocol/fetch_response.rb
- lib/kafka/protocol/group_coordinator_request.rb
- lib/kafka/protocol/group_coordinator_response.rb
- lib/kafka/protocol/heartbeat_request.rb
- lib/kafka/protocol/heartbeat_response.rb
- lib/kafka/protocol/join_group_request.rb
- lib/kafka/protocol/join_group_response.rb
- lib/kafka/protocol/leave_group_request.rb
- lib/kafka/protocol/leave_group_response.rb
- lib/kafka/protocol/list_offset_request.rb
- lib/kafka/protocol/list_offset_response.rb
- lib/kafka/protocol/member_assignment.rb
- lib/kafka/protocol/message.rb
- lib/kafka/protocol/message_set.rb
- lib/kafka/protocol/metadata_request.rb
- lib/kafka/protocol/metadata_response.rb
- lib/kafka/protocol/offset_commit_request.rb
- lib/kafka/protocol/offset_commit_response.rb
- lib/kafka/protocol/offset_fetch_request.rb
- lib/kafka/protocol/offset_fetch_response.rb
- lib/kafka/protocol/produce_request.rb
- lib/kafka/protocol/produce_response.rb
- lib/kafka/protocol/request_message.rb
- lib/kafka/protocol/sasl_handshake_request.rb
- lib/kafka/protocol/sasl_handshake_response.rb
- lib/kafka/protocol/sync_group_request.rb
- lib/kafka/protocol/sync_group_response.rb
- lib/kafka/round_robin_assignment_strategy.rb
- lib/kafka/sasl/gssapi.rb
- lib/kafka/sasl/plain.rb
- lib/kafka/sasl/scram.rb
- lib/kafka/sasl_authenticator.rb
- lib/kafka/snappy_codec.rb
- lib/kafka/socket_with_timeout.rb
- lib/kafka/ssl_context.rb
- lib/kafka/ssl_socket_with_timeout.rb
- lib/kafka/statsd.rb
- lib/kafka/version.rb