Вызывает ли установка 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 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение
  • Вызывает ли установка group.id в потребителе Kafka автоматическую синхронизацию смещения, даже если auto.commit.offset и
    Anonymous » » в форуме JAVA
    0 Ответы
    11 Просмотры
    Последнее сообщение Anonymous
  • Auto.offset.Reset Default для Spring Kafka
    Anonymous » » в форуме JAVA
    0 Ответы
    2 Просмотры
    Последнее сообщение Anonymous
  • Auto.offset.Reset Default для Spring Kafka
    Anonymous » » в форуме JAVA
    0 Ответы
    2 Просмотры
    Последнее сообщение Anonymous
  • Как Kafka Slireeer RE доставляет сообщения, когда начинает потребление сообщений с помощью Auto Commit, установленного н
    Anonymous » » в форуме JAVA
    0 Ответы
    6 Просмотры
    Последнее сообщение Anonymous
  • Visual Studio GIT: «Commit and Push» и «Commit and Sync».
    Anonymous » » в форуме C#
    0 Ответы
    5 Просмотры
    Последнее сообщение Anonymous

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