Class: BPS::Publisher::KafkaAsync

Inherits:

Kafka

• Object
• Abstract
• Kafka
• BPS::Publisher::KafkaAsync

Defined in:

lib/bps/publisher/kafka_async.rb

Defined Under Namespace

Classes: Topic

Constant Summary

Constants inherited from Kafka

BPS::Publisher::Kafka::CLIENT_OPTS, BPS::Publisher::Kafka::PRODUCER_OPTS

Instance Method Summary

• #initialize(broker_addrs, **opts) ⇒ KafkaAsync constructor

  A new instance of KafkaAsync.

Methods inherited from Kafka

#close, coercer, #topic

Constructor Details

#initialize(broker_addrs, **opts) ⇒ KafkaAsync

Returns a new instance of KafkaAsync.

Parameters:

• opts (Hash) —

  the options.

Options Hash (**opts):

• :max_queue_size (Integer) — default: defaults to: 1000 —

  the maximum number of messages allowed in the queue.

• :delivery_threshold (Integer) — default: defaults to: 1000 —

  if greater than zero, the number of buffered messages that will automatically trigger a delivery.

• :delivery_interval (Integer) — default: defaults to: 30 —

  if greater than zero, the number of seconds between automatic message deliveries.

See Also:

• Kafka::Publisher

# File 'lib/bps/publisher/kafka_async.rb', line 22

def initialize(broker_addrs, **opts) # rubocop:disable Lint/UselessMethodDefinition
  super
end