)]}'
{"monasca_common/kafka/consumer.py":[{"author":{"_account_id":15027,"name":"Michael Hoppal","email":"michael.jam.hoppal@hpe.com","username":"michael-hoppal"},"change_message_id":"e19025e3f937036f7a81e1a09e690bc22b489491","unresolved":false,"context_lines":[{"line_number":1,"context_line":"# Copyright (c) 2014, 2015 Hewlett-Packard Development Company, L.P."},{"line_number":2,"context_line":"#"},{"line_number":3,"context_line":"# Licensed under the Apache License, Version 2.0 (the \"License\");"},{"line_number":4,"context_line":"# you may not use this file except in compliance with the License."}],"source_content_type":"text/x-python","patch_set":2,"id":"5a5ae5dd_31f19995","line":1,"range":{"start_line":1,"start_character":22,"end_line":1,"end_character":26},"updated":"2016-02-08 21:17:11.000000000","message":"copyright","commit_id":"72db3311e406c57dc5edf4bf552ad37ede61fbff"},{"author":{"_account_id":7052,"name":"Fabio Giannetti","email":"fgiannet@cisco.com","username":"fabgia"},"change_message_id":"8081605052124e91f88a3807fc4418d85602b36d","unresolved":false,"context_lines":[{"line_number":127,"context_line":"                if message:"},{"line_number":128,"context_line":"                    yield message"},{"line_number":129,"context_line":"                else:"},{"line_number":130,"context_line":"                    time.sleep(0.01)"},{"line_number":131,"context_line":""},{"line_number":132,"context_line":"                if self._commit_callback:"},{"line_number":133,"context_line":"                    time_now \u003d datetime.datetime.now()"}],"source_content_type":"text/x-python","patch_set":4,"id":"5a5ae5dd_047d2be7","line":130,"range":{"start_line":130,"start_character":31,"end_line":130,"end_character":35},"updated":"2016-02-09 01:56:10.000000000","message":"Why the sleep interval is so small?\nWouldn\u0027t his force the Persister to constantly bug Kafka?\nPlease explain","commit_id":"ce75f18ccb777ec352488bce148e83c1f3ac4694"},{"author":{"_account_id":14273,"name":"Joe Keen","email":"joe.keen@hpe.com","username":"jkeen"},"change_message_id":"6092b1e5c2bacb6aebdb138a15a71b414d18331b","unresolved":false,"context_lines":[{"line_number":127,"context_line":"                if message:"},{"line_number":128,"context_line":"                    yield message"},{"line_number":129,"context_line":"                else:"},{"line_number":130,"context_line":"                    time.sleep(0.01)"},{"line_number":131,"context_line":""},{"line_number":132,"context_line":"                if self._commit_callback:"},{"line_number":133,"context_line":"                    time_now \u003d datetime.datetime.now()"}],"source_content_type":"text/x-python","patch_set":4,"id":"5a5ae5dd_38e64845","line":130,"range":{"start_line":130,"start_character":31,"end_line":130,"end_character":35},"in_reply_to":"5a5ae5dd_047d2be7","updated":"2016-02-09 03:18:30.000000000","message":"If we\u0027re optimizing for throughput then we need to keep the waiting here small.  There\u0027s a built in 100ms wait in the Kafka protocol itself that I don\u0027t see a way to modify in the kafka-python library.  This wait is for a situation where the return from Kafka was no data at all so the total wait time would be 110ms plus any scheduling jitter.  That seems more than enough and I saw no adverse effects in my testing.  In other testing Kafka handled requests at a ~30ms interval with no trouble.","commit_id":"ce75f18ccb777ec352488bce148e83c1f3ac4694"}]}