Add bootstrap servers to Kafka Event (#216)

Co-authored-by: Carl Zogheib <[email protected]>

Author: zabrip

aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java

@@ -26,8 +26,9 @@
 /** Represents a Kafka Event. **/
 public class KafkaEvent {
     private Map<String, List<KafkaEventRecord>> records;
-    private  String eventSource;
+    private String eventSource;
     private String eventSourceArn;
+    private String bootstrapServers;
 
     @Data
     @NoArgsConstructor

aws-lambda-java-tests/pom.xml

@@ -44,7 +44,7 @@
         <dependency>
             <groupId>com.amazonaws</groupId>
             <artifactId>aws-lambda-java-events</artifactId>
-            <version>3.6.0</version>
+            <version>3.7.0</version>
         </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
@@ -253,4 +253,4 @@
             </plugin>
         </plugins>
     </build>
-</project>
+</project>

aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java

@@ -78,6 +78,7 @@ public void testLoadKafkaEvent() {
 
         assertThat(event).isNotNull();
         assertThat(event.getEventSourceArn()).isEqualTo("arn:aws:kafka:us-east-1:123456789012:cluster/vpc-3432434/4834-3547-3455-9872-7929");
+        assertThat(event.getBootstrapServers()).isEqualTo("b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092,b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092");
 
         KafkaEvent.KafkaEventRecord record = event.getRecords().get("mytopic-01").get(0);
         assertThat(record.getValue()).decodedAsBase64().asString().isEqualTo("Hello from Kafka !!");

aws-lambda-java-tests/src/test/resources/kafka_event.json

@@ -1,6 +1,7 @@
 {
   "eventSource": "aws:kafka",
   "eventSourceArn": "arn:aws:kafka:us-east-1:123456789012:cluster/vpc-3432434/4834-3547-3455-9872-7929",
+  "bootstrapServers": "b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092,b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",
   "records": {
     "mytopic-01": [
       {
@@ -13,4 +14,4 @@
       }
     ]
   }
-}
+}