def refresh_committed_offsets_if_needed(self):
        if self._subscription.needs_fetch_committed_offsets:
            offsets = self.fetch_committed_offsets(self._subscription.assigned_partitions())
            for partition, offset in six.iteritems(offsets):
                # verify assignment is still active
                if self._subscription.is_assigned(partition):
                    self._subscription.assignment[partition].committed = offset.offset
            self._subscription.needs_fetch_committed_offsets = False
config panel for left-hand-side of frame
dataset/ETHPy150Open dpkp/kafka-python/kafka/coordinator/consumer.py/ConsumerCoordinator.refresh_committed_offsets_if_needed--crossover with--dataset/ETHPy150Open xraypy/xraylarch/plugins/wx/mapimageframe.py/MapImageFrame.CustomConfig