async def METHOD_NAME(self, handler: Callable):
    self._print('Start consuming messages asynchronously.')
    for message in self.consumer:
        self.__print_message(message)
        data = self.__deserialize_message(message.value)
        await handler(data)