examples update

Author: hjgraca

examples/Kafka/Avro/src/Avro.csproj

@@ -24,12 +24,7 @@
         <ProjectReference Include="..\..\..\..\libraries\src\AWS.Lambda.Powertools.Kafka.Avro\AWS.Lambda.Powertools.Kafka.Avro.csproj" />
     </ItemGroup>
     <Target Name="GenerateAvroClasses" BeforeTargets="CoreCompile">
-        <Exec Command="avrogen -s $(ProjectDir)AvroProduct.avsc $(ProjectDir)Generated"/>
-        <Exec Command="avrogen -s $(ProjectDir)AvroKey.avsc $(ProjectDir)Generated"/>
-        <Exec Command="avrogen -s $(ProjectDir)Payload.avsc $(ProjectDir)Generated"/>
-        <ItemGroup>
-            <Compile Include="$(ProjectDir)Generated/**/*.cs"/>
-        </ItemGroup>
+        <Exec Command="avrogen -s $(ProjectDir)CustomerProfile.avsc $(ProjectDir)Generated"/>
     </Target>
     <ItemGroup>
         <None Remove="kafka-avro-event.json" />

examples/Kafka/Avro/src/AvroKey.avsc

@@ -2,10 +2,10 @@
 using Amazon.Lambda.RuntimeSupport;
 using AWS.Lambda.Powertools.Kafka;
 using AWS.Lambda.Powertools.Kafka.Avro;
-using AWS.Lambda.Powertools.Kafka.Tests;
 using AWS.Lambda.Powertools.Logging;
+using com.example;
 
-string Handler(ConsumerRecords<AvroKey, AvroProduct> records, ILambdaContext context)
+string Handler(ConsumerRecords<string, CustomerProfile> records, ILambdaContext context)
 {
     foreach (var record in records)
     {
@@ -15,8 +15,7 @@ string Handler(ConsumerRecords<AvroKey, AvroProduct> records, ILambdaContext con
     return "Processed " + records.Count() + " records";
 }
 
-
-await LambdaBootstrapBuilder.Create((Func<ConsumerRecords<AvroKey, AvroProduct>, ILambdaContext, string>?)Handler,
+await LambdaBootstrapBuilder.Create((Func<ConsumerRecords<string, CustomerProfile>, ILambdaContext, string>?)Handler,
         new PowertoolsKafkaAvroSerializer()) // Use PowertoolsKafkaAvroSerializer for Avro serialization
     .Build()
     .RunAsync();