Crate kinesis_firehose_producer

Kinesis Firehose producer utility

Handles buffering, retries, and limits

Available flavours:

• async_producer::Producer
• sync_producer::Producer
• async_producer_pool::AsyncProducerPool

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