Как обработать ошибку внутри функции, которая внутри цикла, не прерывая цикл в Python?

Есть некий класс:

class ExampleClass:
    def method_1(self, p1):
        # Do something 1

    def method_2(self, p1):
        # Do something 2

    def method_3(self, p1):
        # Do something 3

    def procerror(self, message):
        method_1(message)
        method_2(message)
        method_3(message)

    def listen_kafka(self, p1):
        kafka = Kafka()
        kafka.listen(procerror)


class Kafka:
    def listen(self, func_to_execute):
        # Listen kafka
        # ... some code for connet to kafka
        for message in 
            func_to_execute(message.value)

Это очень упрощенный код
На каждое сообщение в кафке, я последовательно вызываю методы класса ExampleClass. Предположим в методе method_2 появилась ошибка, я ее обработал, записал логи, как сделать так, чтобы программа не остановилась но при этом и следующие методы не сработали?
Надо просто пропустить сообщение и перейти на следующее сообщение из кафки