DataDog/pykafka — comment on commit 49dce3d8bddf5f10aea8bd97622ef8ba9daaaa24
File: kafka/base.py line 511
By ormsbee:

Hah. Yeah. I ended up using end_offsets in my tests because otherwise the tests would never terminate. Doh. Thank you.