Closed rafalp closed 2 years ago
@hramezani I've merged your PR but test cases aren't good - they hang causing tests suite to timeout.
I've given this some attention and found that Kafka backend is hanging withing next_published
, with await self._consumer.getone()
never returning.
I've skipped Kafka for now. I'm cleaning this project. I'll fix the test before I finish the cleanup.
Pipeline is already green with 88% coverage, and Kafka test skipped.
This PR might be related.