Как работать с контрольной точкой на EventHub ConsumerGroup

Question

Я пытаюсь работать с Eventhub и группами потребителей. Мое намерение состоит в том, чтобы сохранить контрольную точку после чтения «n». Но я не могу найти способ сделать это. С помощью nodejs или Java API, как я могу это сделать? Если я сохраню контрольную точку и перезагружу приложение, оно должно прочитать с контрольной точки, верно?

Answer 1

Чтобы использовать nodejs для установки контрольной точки, вы можете следовать моему предыдущему ответу здесь .

Если я сохраняю контрольную точку и перезагружаю приложение, оно должно читаться справа от контрольной точки?

Да, поскольку контрольная точка хранится в хранилище BLOB-объектов Azure, eph знает, с чего начать чтение данных события.

Для ваших вопросов в комментариях: Но этоМне не ясно, в чем разница между контрольной точкой и смещением

Контрольной точкой, вы можете рассматривать ее как действие или метод, после выполнения метода контрольной точки в коде (вы можете найти его в моемответьте в приведенной выше ссылке), затем в хранилище BLOB-объектов создается файл json. А в файле json он определяет смещение / порядковый номер, которые используются eph для определения, где вы можете начать читать данные события. Вы можете сослаться на этот скриншот файла json: