Функция Python Azure Kafka Triggered - autoOffsetReset как последняя версия в host.json не работает ⇐ Python

[Anonymous]

Когда я выполняю новое развертывание, мое функциональное приложение, запускаемое Kafka, начинает принимать данные за последние 7 дней. Это занимает огромное количество времени. Итак, я хочу прочитать данные и вставить в базу данных самые последние данные, а не с самого начала. Поэтому я использую флаг autoOffsetReset как последний (при условии, что этот параметр соответствует моим требованиям). Мой файл host.json

Код: Выделить всё

{
"version": "2.0",
"extensions": {
"kafka": {
"autoOffsetReset": "latest"
}
},
"logging": {
"applicationInsights": {
"samplingSettings": {
"isEnabled": true,
"excludedTypes": "Request"
}
}
},
"extensionBundle": {
"id": "Microsoft.Azure.Functions.ExtensionBundle",
"version": "[3.*, 4.0.0)"
}
}

Function.json --- ЦЕНТР СОБЫТИЙ

Код: Выделить всё

{
"scriptFile": "main.py",
"bindings": [
{
"type" : "kafkaTrigger",
"direction": "in",
"name" : "kevents",
"protocol" : "SASLSSL",
"password" : "EventHubConnectionString",
"topic" : "message_python",
"authenticationMode" : "PLAIN",
"cardinality" : "MANY",
"dataType": "string",
"consumerGroup" : "$Default",
"username" : "$ConnectionString",
"BrokerList" : "%BrokerList%"
}
]
}

main.py

Код: Выделить всё

import logging
import typing
from azure.functions import KafkaEvent

def main(kevents : typing.List[KafkaEvent]):
for event in kevents:
logging.info(event.get_body())

Я пробовал разные настройки host.json, но не могу прочитать последние события при новых развертываниях. Вместо этого он считывает данные за последние 7 дней.

Подробнее здесь: https://stackoverflow.com/questions/787 ... ost-json-n