)]}'
{"lower-constraints.txt":[{"author":{"_account_id":17669,"name":"Doug Szumski","email":"doug@stackhpc.com","username":"DougSzumski"},"change_message_id":"4d26e614405d120e72b70bdc62efaa8b0c6a3419","unresolved":false,"context_lines":[{"line_number":22,"context_line":"linecache2\u003d\u003d1.0.0"},{"line_number":23,"context_line":"mccabe\u003d\u003d0.4.0"},{"line_number":24,"context_line":"mock\u003d\u003d2.0.0"},{"line_number":25,"context_line":"monasca-common\u003d\u003d2.14.0"},{"line_number":26,"context_line":"monotonic\u003d\u003d0.6"},{"line_number":27,"context_line":"mox3\u003d\u003d0.20.0"},{"line_number":28,"context_line":"msgpack-python\u003d\u003d0.4.0"}],"source_content_type":"text/plain","patch_set":8,"id":"7faddb67_16789ac1","line":25,"range":{"start_line":25,"start_character":21,"end_line":25,"end_character":22},"updated":"2019-08-06 16:31:35.000000000","message":"Should we bump this when this is merged? https://review.opendev.org/#/c/674804/\n(same for requirements.txt)","commit_id":"135c8ceb7506634afb2c2820c921bdd18b070e6c"},{"author":{"_account_id":16222,"name":"witek","email":"witold.bedyk@suse.com","username":"witek"},"change_message_id":"0bfe52bec84fb4ad84dc142539e534216e228e29","unresolved":false,"context_lines":[{"line_number":22,"context_line":"linecache2\u003d\u003d1.0.0"},{"line_number":23,"context_line":"mccabe\u003d\u003d0.4.0"},{"line_number":24,"context_line":"mock\u003d\u003d2.0.0"},{"line_number":25,"context_line":"monasca-common\u003d\u003d2.14.0"},{"line_number":26,"context_line":"monotonic\u003d\u003d0.6"},{"line_number":27,"context_line":"mox3\u003d\u003d0.20.0"},{"line_number":28,"context_line":"msgpack-python\u003d\u003d0.4.0"}],"source_content_type":"text/plain","patch_set":8,"id":"7faddb67_75ebf211","line":25,"range":{"start_line":25,"start_character":21,"end_line":25,"end_character":22},"in_reply_to":"7faddb67_16789ac1","updated":"2019-08-07 11:01:12.000000000","message":"Yeah, I\u0027ll mark this with Workflow -1 until then.","commit_id":"135c8ceb7506634afb2c2820c921bdd18b070e6c"}],"monasca_persister/kafka/confluent_kafka_persister.py":[{"author":{"_account_id":26141,"name":"Adrian Czarnecki","email":"adrian.czarnecki@ts.fujitsu.com","username":"czarneckia"},"change_message_id":"fdd8613cc64481bf4cc19052c467822d70c8348f","unresolved":false,"context_lines":[{"line_number":34,"context_line":"        return raw_message"},{"line_number":35,"context_line":""},{"line_number":36,"context_line":"    @staticmethod"},{"line_number":37,"context_line":"    def flush(kafka_consumer, partitions):"},{"line_number":38,"context_line":"        p \u003d ConfluentKafkaPersister()"},{"line_number":39,"context_line":"        p._flush()"}],"source_content_type":"text/x-python","patch_set":8,"id":"7faddb67_56e4eb3b","line":37,"range":{"start_line":37,"start_character":14,"end_line":37,"end_character":40},"updated":"2019-08-05 13:33:02.000000000","message":"This variable are not used, Can we remove this?","commit_id":"135c8ceb7506634afb2c2820c921bdd18b070e6c"},{"author":{"_account_id":16222,"name":"witek","email":"witold.bedyk@suse.com","username":"witek"},"change_message_id":"97c2e84c8ecf1e0d9ddd5b5cbc6160bf0176e0ca","unresolved":false,"context_lines":[{"line_number":34,"context_line":"        return raw_message"},{"line_number":35,"context_line":""},{"line_number":36,"context_line":"    @staticmethod"},{"line_number":37,"context_line":"    def flush(kafka_consumer, partitions):"},{"line_number":38,"context_line":"        p \u003d ConfluentKafkaPersister()"},{"line_number":39,"context_line":"        p._flush()"}],"source_content_type":"text/x-python","patch_set":8,"id":"7faddb67_2cc1de54","line":37,"range":{"start_line":37,"start_character":14,"end_line":37,"end_character":40},"in_reply_to":"7faddb67_56e4eb3b","updated":"2019-08-05 13:46:56.000000000","message":"No, the method is used as `on_revoke` callback [1, 2] and the interface must fit.\n\n[1] https://opendev.org/openstack/monasca-common/src/branch/master/monasca_common/confluent_kafka/consumer.py#L59\n[2] https://docs.confluent.io/current/clients/confluent-kafka-python/#confluent_kafka.Consumer.subscribe","commit_id":"135c8ceb7506634afb2c2820c921bdd18b070e6c"}]}