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