Kafka consumer fix
Add core.async dep