diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java index ed5c2ac8..dfd97056 100644 --- a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java +++ b/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> records; - private String eventSource; + private String eventSource; private String eventSourceArn; + private String bootstrapServers; @Data @NoArgsConstructor diff --git a/aws-lambda-java-tests/pom.xml b/aws-lambda-java-tests/pom.xml index 0b734a9b..97c2212d 100644 --- a/aws-lambda-java-tests/pom.xml +++ b/aws-lambda-java-tests/pom.xml @@ -44,7 +44,7 @@ com.amazonaws aws-lambda-java-events - 3.6.0 + 3.7.0 org.junit.jupiter @@ -253,4 +253,4 @@ - \ No newline at end of file + diff --git a/aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java b/aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java index 61d9eaf1..aecd0c6a 100644 --- a/aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java +++ b/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 !!"); diff --git a/aws-lambda-java-tests/src/test/resources/kafka_event.json b/aws-lambda-java-tests/src/test/resources/kafka_event.json index ad089134..8a553e26 100644 --- a/aws-lambda-java-tests/src/test/resources/kafka_event.json +++ b/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 @@ } ] } -} \ No newline at end of file +}