Есть некий класс:
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 появилась ошибка, я ее обработал, записал логи, как сделать так, чтобы программа не остановилась но при этом и следующие методы не сработали?
Надо просто пропустить сообщение и перейти на следующее сообщение из кафки