使用 的 Amazon MSK範例 AWS SDK for .NET - AWS SDK for .NET
無伺服器範例

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 的 Amazon MSK範例 AWS SDK for .NET

下列程式碼範例示範如何搭配 AWS SDK for .NET Amazon 使用 來執行動作和實作常見案例MSK。

每個範例都包含完整原始程式碼的連結，您可以在其中找到如何在內容中設定和執行程式碼的指示。

無伺服器範例

下列程式碼範例示範如何實作 Lambda 函數，該函數接收從 Amazon MSK叢集接收記錄所觸發的事件。函數會擷取MSK承載並記錄記錄內容。

AWS SDK for .NET
注意

還有更多 。 GitHub尋找完整範例，並了解如何在無伺服器範例儲存庫中設定和執行。

使用 使用 Lambda 來使用 Amazon MSK事件NET。

using System.Text;
using Amazon.Lambda.Core;
using Amazon.Lambda.KafkaEvents;


// Assembly attribute to enable the Lambda function's JSON input to be converted into a .NET class.
[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]

namespace MSKLambda;

public class Function
{
    
    
    /// <param name="input">The event for the Lambda function handler to process.</param>
    /// <param name="context">The ILambdaContext that provides methods for logging and describing the Lambda environment.</param>
    /// <returns></returns>
    public void FunctionHandler(KafkaEvent evnt, ILambdaContext context)
    {

        foreach (var record in evnt.Records)
        {
            Console.WriteLine("Key:" + record.Key); 
            foreach (var eventRecord in record.Value)
            {
                var valueBytes = eventRecord.Value.ToArray();    
                var valueText = Encoding.UTF8.GetString(valueBytes);
                
                Console.WriteLine("Message:" + valueText);
            }
        }
    }
    

}