【Azure 应用服务】本地创建Azure Function Kafka Trigger 函数和Kafka output的HTTP Trigger函数实验

问题描述

在上一篇博文(https://www.cnblogs.com/lulight/p/16525902.html)中，我们成功的以VM作为Kafka服务器运行，并且验证了从其他机器中远程访问。在本文中，将使用Visual Studio 2022创建Azure Function 作为生产者和消费者在本地进行验证

• 生产者：使用HTTP Trigger函数，以 kafka output 作为输出
• 消费者：使用Kafka Trigger函数

解题步骤

1：打开VS 2022，开始创建Azure Funciton工程

2：选择 Azure Function模板，并使用.NET 6.0作为运行时，然后选择 Kafka Trigger。其他值保持默认即可。保存。

3:   把BorkerList添加到本地配置文件中（ local.settings.json ），然后修改正确的topic名称。因为Kafka服务器没有启用SSL和Password，所以这里 Protocol 和 AuthenticationMode 都需要修改为 NotSet。 

local.setting.json 配置文件：

{
    "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet",
    "BrokerList": "xxx.xxx.xxx.xxx:9092",
    "KafkaPassword": "",
    "ConnectionString": ""
  }
}