Commit 2eb3f70
File tree
- aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events
- aws-lambda-java-tests
- src/test
- java/com/amazonaws/services/lambda/runtime/tests
- resources
Lines changed: 2 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -26,8 +26,9 @@ | |||
| 26 | 26 | /** Represents a Kafka Event. **/ | |
| 27 | 27 | public class KafkaEvent { | |
| 28 | 28 | private Map<String, List<KafkaEventRecord>> records; | |
| 29 | - private String eventSource; | ||
| 29 | + private String eventSource; | ||
| 30 | 30 | private String eventSourceArn; | |
| 31 | + private String bootstrapServers; | ||
| 31 | 32 | ||
| 32 | 33 | @Data | |
| 33 | 34 | @NoArgsConstructor | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -44,7 +44,7 @@ | |||
| 44 | 44 | <dependency> | |
| 45 | 45 | <groupId>com.amazonaws</groupId> | |
| 46 | 46 | <artifactId>aws-lambda-java-events</artifactId> | |
| 47 | - <version>3.6.0</version> | ||
| 47 | + <version>3.7.0</version> | ||
| 48 | 48 | </dependency> | |
| 49 | 49 | <dependency> | |
| 50 | 50 | <groupId>org.junit.jupiter</groupId> | |
@@ -253,4 +253,4 @@ | |||
| 253 | 253 | </plugin> | |
| 254 | 254 | </plugins> | |
| 255 | 255 | </build> | |
| 256 | - </project> | ||
| 256 | + </project> | ||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -78,6 +78,7 @@ public void testLoadKafkaEvent() { | |||
| 78 | 78 | ||
| 79 | 79 | assertThat(event).isNotNull(); | |
| 80 | 80 | 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"); | ||
| 81 | 82 | ||
| 82 | 83 | KafkaEvent.KafkaEventRecord record = event.getRecords().get("mytopic-01").get(0); | |
| 83 | 84 | assertThat(record.getValue()).decodedAsBase64().asString().isEqualTo("Hello from Kafka !!"); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1,6 +1,7 @@ | |||
| 1 | 1 | { | |
| 2 | 2 | "eventSource": "aws:kafka", | |
| 3 | 3 | "eventSourceArn": "arn:aws:kafka:us-east-1:123456789012:cluster/vpc-3432434/4834-3547-3455-9872-7929", | |
| 4 | + "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", | ||
| 4 | 5 | "records": { | |
| 5 | 6 | "mytopic-01": [ | |
| 6 | 7 | { | |
@@ -13,4 +14,4 @@ | |||
| 13 | 14 | } | |
| 14 | 15 | ] | |
| 15 | 16 | } | |
| 16 | - } | ||
| 17 | + } | ||
0 commit comments