def METHOD_NAME(self, mock_iter, mock_update):
    since = get_topic_offset(topics.DOMAIN)
    pillow = get_domain_kafka_to_elasticsearch_pillow()
    pillow.process_changes(since=since, forever=True)
    self.assertFalse(mock_update.called)