94e0a059b5
PROBLEM: Consumer offset was resetting to the latest index rather than the earliest SOLUTION: Modified consumer creation to include `auto_offset_reset="smallest"` which allows the offset to reset to the earliest known index. NOTE: This does exactly what the whence parameter in SimpleConsumer.seek() is expected to do, however in order to achieve this functionality, the parameter `auto_offset_reset` MUST be set to either "largest" or "smallest". Change-Id: I887892d80f2da9619c7f11737b3ab2e1d1dacf1e |
||
---|---|---|
.. | ||
healthcheck | ||
kafka | ||
kafka_lib | ||
monasca_query_language | ||
repositories | ||
rest | ||
simport | ||
tests | ||
validation | ||
__init__.py |