Каковы различные причины этих трех сообщений об ошибках Kafka «Ошибка при фиксации смещения»? - PullRequest
0 голосов
/ 19 июня 2020

Может ли кто-нибудь помочь мне лучше понять эти 3 типа ошибок? Я предполагаю, что все они в некоторой степени связаны с перебалансировкой группы или медленными потребителями, но я не совсем уверен, что будет выброшено при каком условии, и что может быть исправлением?

1

Offset commit failed on partition xxx at offset xxx: The request timed out.

2

Offset commit failed on partition xxx at offset xxx: This is not the correct coordinator.

3

Offset commit failed on partition xxx at offset xxx: The coordinator is not aware of this member.

Обычно за этим следует org.apache.kafka.clients.consumer.CommitFailedException.

...