Блог

Как я могу начать чтение тематических сообщений с определенной точки с помощью триггера Azure? Я видел объяснение того, как это сделать, используя флаг «—offset», но триггер не раскрывает этого.

Я создаю новую интеграцию для существующей темы с большой скоростью потока данных и определенно не хочу получать все предыдущие сообщения (независимо от срока хранения этого клиента). Это моя первая попытка работать с Кафкой.

Ниже приведен код для вычисления смещения

 var config = new ConsumerConfig
{
    ...
    EnableAutoCommit = true // (the default)
    EnableAutoOffsetStore = false
}

...

while (!cancelled)
{
    var consumeResult = consumer.Consume(cancellationToken);

    // process message here.

    consumer.StoreOffset(consumeResult);
}
 

Для получения дополнительной информации проверьте Смещение Кафки.

Также проверьте триггер Кафки для получения полной информации.