TODO: Remove and provide better may to get the device id GetDeviceIdFromTopic extract the deviceId from the topic name.

Load is used to calculate average load.

Keys are distributed among partitions.

Represents how many times a node is replicated on the consistent ring.

60000 milliseconds - to handle a wider latency range.

SaramaClient represents the messaging proxy.

A Topic definition - may be augmented with additional attributes eventually.

MsgClient represents the set of APIs a Kafka MsgClient must implement.

Member represents a member on the consistent ring.