class Kafka::Client

def async_producer(delivery_interval: 0, delivery_threshold: 0, max_queue_size: 1000, **options)

Returns:
  • (AsyncProducer) -

Other tags:
    See: AsyncProducer -

Parameters:
  • delivery_interval (Integer) -- if greater than zero, the number of
  • delivery_threshold (Integer) -- if greater than zero, the number of
  • max_queue_size (Integer) -- the maximum number of messages allowed in 
def async_producer(delivery_interval: 0, delivery_threshold: 0, max_queue_size: 1000, **options)
  sync_producer = producer(**options)
  AsyncProducer.new(
    sync_producer: sync_producer,
    delivery_interval: delivery_interval,
    delivery_threshold: delivery_threshold,
    max_queue_size: max_queue_size,
    instrumenter: @instrumenter,
    logger: @logger,
  )
end