Initial version which can receive Apache access logs from a Kafka topic