Повторяет ли Faust Streaming Consumer фиксацию смещения в случае неудачи?
После изучения журналов потребителей я обнаружил следующую ошибку:
[ERROR] OffsetCommit failed for group gaming-processor on partition TopicPartition(topic='my_topic', partition=3) with offset OffsetAndMetadata(offset=29426192, metadata=''): UnknownTopicOrPartitionError
Эта ошибка возникла, когда мой kafka broker leader pod на GKE вращался. Я думаю, что эта ошибка ожидается во время ребалансировки. Мой вопрос заключается в том, будет ли приложение повторять попытку зафиксировать это смещение снова или оно зафиксирует только следующее смещение в следующей волне фиксации? Кроме того, я хотел бы знать, может ли это привести к повторному чтению потребителем старых сообщений, которые уже были потреблены, или к потере любого сообщения, которое еще не было потреблено.