Add bootstrap servers to Kafka Event (#216) · maxday/aws-lambda-java-libs@2eb3f70 · GitHub
Skip to content

Commit 2eb3f70

Browse files
zabripcarlzogh
andauthored
Add bootstrap servers to Kafka Event (aws#216)
Co-authored-by: Carl Zogheib <11421173+carlzogh@users.noreply.github.com>
1 parent c491aa2 commit 2eb3f70

4 files changed

Lines changed: 7 additions & 4 deletions

File tree

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

Lines changed: 2 additions & 1 deletion

‎aws-lambda-java-tests/pom.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@
4444
<dependency>
4545
<groupId>com.amazonaws</groupId>
4646
<artifactId>aws-lambda-java-events</artifactId>
47-
<version>3.6.0</version>
47+
<version>3.7.0</version>
4848
</dependency>
4949
<dependency>
5050
<groupId>org.junit.jupiter</groupId>
@@ -253,4 +253,4 @@
253253
</plugin>
254254
</plugins>
255255
</build>
256-
</project>
256+
</project>

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ public void testLoadKafkaEvent() {
7878

7979
assertThat(event).isNotNull();
8080
assertThat(event.getEventSourceArn()).isEqualTo("arn:aws:kafka:us-east-1:123456789012:cluster/vpc-3432434/4834-3547-3455-9872-7929");
81+
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");
8182

8283
KafkaEvent.KafkaEventRecord record = event.getRecords().get("mytopic-01").get(0);
8384
assertThat(record.getValue()).decodedAsBase64().asString().isEqualTo("Hello from Kafka !!");

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

Lines changed: 2 additions & 1 deletion

0 commit comments

Comments
 (0)