I am trying to create a Azure function app Kafka trigger which starts reading messages from a given offset. I should be able to change the offset and the trigger should start reading messages from the specified offset accordingly. I looked into the Azure function app Kafka trigger configurations and I don't see anything available to specify the offset.
Here are the available configuration for Azure function trigger:
function.json
{
"bindings": [
{
"type": "kafkaTrigger",
"name": "event",
"direction": "in",
"topic": "topic",
"brokerList": "%BrokerList%",
"username": "%ConfluentCloudUserName%",
"password": "%ConfluentCloudPassword%",
"protocol": "saslSsl",
"authenticationMode": "plain",
"consumerGroup" : "$Default",
"dataType": "string"
}
]
}
host.json
{
"version": "2.0",
"extensions": {
"kafka": {
"maxBatchSize": 64,
"SubscriberIntervalInSeconds": 1,
"ExecutorChannelCapacity": 1,
"ChannelFullRetryIntervalInMs": 50
}
}
}
Any alternate approaches are welcome.