Вызывает ли установка group.id в потребителе Kafka автоматическую синхронизацию смещения, даже если auto.commit.offset иJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Вызывает ли установка group.id в потребителе Kafka автоматическую синхронизацию смещения, даже если auto.commit.offset и

Сообщение Anonymous »

Каждый раз, когда groupId настроен в потребительском свойстве, несмотря на то, что для auto.commit.offset установлено значение true или false, я получаю синхронизацию между смещением потребления при опросе. При первом опросе я получил 500 смещений (от 0-го смещения до 500) и без синхронизации вручную (consumer.sync() или Consumer.async()) я остановил код, при выполнении во второй раз после опроса я получил 500 смещения (от 500 до 1000).

Для первого запуска
Изображение

Для второго запуска
< img alt="введите здесь описание изображения" src="https://i.sstatic.net/oJ5q6dCA.png" />
Я не перенес управление программой в строку кода Consumer.sync() ни в работает,
Это произошло несмотря на то, что я установил для «enable.auto.commit» значение true или false
Если это так, то какова цель этого «enable.auto» Свойство .commit.

Подробнее здесь: https://stackoverflow.com/questions/793 ... ronization
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»