Start trying core async
Working pubsub using core.async and kafka