Working pubsub using core.async and kafka