def METHOD_NAME(self):
    feed = KafkaChangeFeed(topics=[topics.FORM_SQL, topics.CASE_SQL], client_id='test-kafka-feed', strict=True)
    first_available_offsets = get_multi_topic_first_available_offsets([topics.FORM_SQL, topics.CASE_SQL])
    since = {
        topic_partition: offset - 1
        for topic_partition, offset in first_available_offsets.items()
    }
    with self.assertRaises(UnavailableKafkaOffset):
        next(feed.iter_changes(since=since, forever=False))