Управление смещением Kafka: enable.auto.commit против enable.auto.offset.store - PullRequest
0 голосов
/ 23 октября 2019

A Kafka Consumer по умолчанию периодически фиксирует текущие смещения, если он не отключен путем отключения enable.auto.commit. В соответствии с документацией вы сами несете ответственность за внесение компенсаций. Поэтому, когда я хочу ручное управление, кажется, что это путь, однако документация также упоминает сохраненные смещения, и что если вы хотите ручное управление, выследует отключить enable.auto.offset.store и использовать rd_kafka_offsets_store() и оставить автоматическую фиксацию без изменений.

Может кто-нибудь объяснить, почему последний подход предпочтительнее? Отключение автоматической фиксации должно иметь точно такой же эффект?

...