Move part related to broker request to common. Switch get requests for producer from receiver to broker

Try to crate/get auto_id again in case of problem. This does happen when several receivers create new collection.

Rename message_id to time_id. Use _id for sequential message index given by producer and time_id for message based on arrival time.

Fix stream_delete functionality. Now stream metadata, auto_incrementing_id and list of streams are cleaned up.

This reverts commit e4f9d3e4.

Adds rdkafka dependency, rdkafka client,
and notification for file close event

Adds rdkafka dependency, rdkafka client,
and notification for file close event