remove dependency on Kafka