Currently, withKinesisProducer kont creates a producer that just stays alive indefinitely until the current thread exits. It would be better for the following to occur once kont exits:
Close the message queue.
Gracefully flush the queue to Kinesis, with a configurable timeout.
Currently,
withKinesisProducer kont
creates a producer that just stays alive indefinitely until the current thread exits. It would be better for the following to occur oncekont
exits: