Online fixes from recent refactor (configuration + submodule restructuring)

This PR fixes a couple of issues associated with the refactoring in stream.py regarding handling of configuration files and location of modules. Also an unrelated fix for a bug was identified in utils.KafkaConsumer. In python 3, the timestamp used in Kafka messages is expected to be in milliseconds and of integer type.