Use BulkProcessor feature

We want to use BulkProcessor feature to handle bulk operations and close nicely bulk and remaining operations when removing/stopping the river.

Also Bulk Processor allows to flush every x seconds when a small amount of data have been processed.

Closes #41.
(cherry picked from commit 05d2d8d)