| commit | fb218002e1c9d2a2139d93bbd83bc69110199ac8 | [log] [tgz] |
|---|---|---|
| author | Micah Whitacre <mkwhit@gmail.com> | Tue Jun 28 15:44:15 2016 -0500 |
| committer | Micah Whitacre <mkwhit@gmail.com> | Tue Jul 05 16:02:36 2016 -0500 |
| tree | 266c9705ef73a516c88e26b94211c67cd071e201 | |
| parent | 360d72a4f887505e020fdb8f99c3ccb1800693f6 [diff] |
CRUNCH-609: Improved KafkaRecordReader to keep retrying when the range of offsets has not been fully consumed.