Implemented RiemannConsumer.
KafkaMetricsReport fixes.