Kafka enable.auto.commit = true и используется commitSyn c ()

Question

Рекомендуется использовать commitSync(), только если enable.auto.commit установлено на false. Но мы использовали commitSync() и забыли установить enable.auto.commit на false. Поэтому я хотел знать, что будет в этом случае?

Answer 1

Если enable.auto.commit установлено на True, то смещение потребителя периодически фиксируется в фоновом режиме. С другой стороны, commitSync() является блокирующим вызовом, который позволяет фиксировать смещения вручную.

В вашем случае смещения будут зафиксированы в обоих случаях:

• Каждый раз, когда вы звоните commitSync()

• Каждый N мс, где N является настраиваемым параметром (auto.commit.interval.ms)