Refactor csv input processing. Add support for kafka interfaces. Fix bug in join...