monasca-common/monasca_common
Habeeb Mohammed 94e0a059b5 Fixed inconfigurable kafka consumer offset location
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
2017-09-27 14:35:00 -06:00
..
healthcheck Invalid kafka check script name 2016-04-05 06:17:46 +02:00
kafka Fixed inconfigurable kafka consumer offset location 2017-09-27 14:35:00 -06:00
kafka_lib [doc] Fix sublist formatting in monasca_common/kafka_lib/NOTES.md 2017-06-08 15:25:50 +00:00
monasca_query_language Add a query language for group, inhibit, and silence rules 2017-06-16 22:42:20 +00:00
repositories Remove unnecessary executable permissions 2016-05-24 09:28:30 +02:00
rest Make monasca-common pep8 compatible 2016-06-04 09:22:43 +00:00
simport TrivialFix: Remove logging import unused 2016-09-23 17:07:11 +07:00
tests Add a query language for group, inhibit, and silence rules 2017-06-16 22:42:20 +00:00
validation Migrate to ostestr framework and PY3 2017-03-02 19:51:04 +01:00
__init__.py Remove unnecessary executable permissions 2016-05-24 09:28:30 +02:00