public static IActionResult Run()

in Functions.Templates/Templates/KafkaOutput-CSharp/run.csx [12:31]


public static IActionResult Run(
    HttpRequest req,
    out string eventData,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    string message = req.Query["message"];

    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
    dynamic data = JsonConvert.DeserializeObject(requestBody);
    message = message ?? data?.message;

    string responseMessage = string.IsNullOrEmpty(message)
        ? "This HTTP triggered function executed successfully. Pass a message in the query string"
        : $"Message {message} sent to the broker. This HTTP triggered function executed successfully.";
    eventData = $"Received message: {message}";

    return new OkObjectResult(responseMessage);
}