fix getting kafka aioread exception