Streams log file reader with threading & polling and then publishes into Kafka