CommitSyn c в Kafka

Question

Я использую commitSync() после обработки сообщений в Кафке. Я хотел знать, сколько времени commitSync() пытается зафиксировать, прежде чем возникнет ошибка? И если он выдаст ошибку, то будет ли это сообщение повторно опрошено позже или предполагается, что оно будет использовано?

Answer 1

Если вы не укажете тайм-аут, commitSync() блокируется на время, указанное default.api.timeout.ms. По умолчанию это 60 секунд.

В случае сбоя этот потребительский экземпляр больше не будет опрашивать те же сообщения, он считается использованным.

Однако, если этот потребительский экземпляр должен был sh, новый экземпляр, использующий ту же группу потребителей, будет перезапущен с последней успешно зафиксированной позиции.