def _update_produced_offsets(self):
        for partition in self._client.get_partition_ids_for_topic(self._topic):
            reqs = [OffsetRequest(self._topic, partition, -1, 1)]

            (resp,) = self._client.send_offset_request(reqs)

            check_error(resp)
            assert resp.topic == self._topic
            assert resp.partition == partition
            self._offsets.produced[partition] = resp.offsets[0]
Decodes an inventory submission, which is a plist-encoded
dataset/ETHPy150Open scrapinghub/frontera/frontera/contrib/messagebus/kafka/__init__.py/OffsetsFetcher._update_produced_offsets--crossover with--dataset/ETHPy150Open munki/munkiwebadmin/inventory/views.py/decode_to_string