added mapper and input format to read events from /kafka.export.* directories instead of kafka