consumer_timeout ignored?
Đang mở
priority:low
- Ngôn ngữ chính
- Python
- Star
- 1.4k
- Fork
- 269
- Merge trung bình
- 1 ngày 1 giờ
- Pull request đã merge (30 ngày)
- 6
Mô tả
Hi,
when I run aiokafka consumer with consumer_timeout=100, it should terminate 100ms after reaching the end of the topic; instead (as demonstrated in the attached notebook) it hangs on, presumably waiting for the next record to show up, until terminated from keyboard.
Is it a bug or am I doing something wrong?
Thanks a lot!
[consumer_timeout ignored.zip](https://github.com/aio-libs/aiokafka/files/820863/consumer_timeout.ignored.zip)
Hướng dẫn đóng góp
Đánh giá
Issue này chưa được đánh giá.