Crate kinesis_firehose_producer[][src]

Kinesis Firehose producer utility

Handles buffering, retries, and limits

Available flavours:

Limitations / decisions:

  • Adds newlines (\n) to records on the way out
  • Attempts to buffer the maximum amount (500 records)
  • Will always retry requests 10 times, waiting a constant time between attempts
  • Probably others

See examples for usage.

Modules

async_producer

Async Producer

async_producer_pool

A Pool of Async Producers

error
sync_producer

Sync Producer