Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added event class MskFirehoseEvent.java for Firehose Lambda transformation when MSK is the source #490

Merged
merged 28 commits into from
Jul 10, 2024
Merged
Changes from 1 commit
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
ec8dca0
Create MskFirehoseEvent.java
ShashankAWS Jul 1, 2024
7df3645
Update MskFirehoseEvent.java
ShashankAWS Jul 1, 2024
f6f4a60
Update MskFirehoseEvent.java
ShashankAWS Jul 1, 2024
51b2640
Update MskFirehoseEvent.java
ShashankAWS Jul 1, 2024
7d689bb
Update README.md
ShashankAWS Jul 1, 2024
eb08bbe
Update and rename MskFirehoseEvent.java to MSKFirehoseEvent.java
ShashankAWS Jul 1, 2024
5eb7042
Create MSKFirehoseResponse.java
ShashankAWS Jul 2, 2024
a720f87
Create msk_firehose_event.json
ShashankAWS Jul 2, 2024
df1e0e4
Create MSKFirehoseEventHandler.java
ShashankAWS Jul 2, 2024
57a9a81
Create MSKFirehoseEventHandlerTest.java
ShashankAWS Jul 2, 2024
5ba689e
Create event.json
ShashankAWS Jul 2, 2024
f240a62
Update README.md
ShashankAWS Jul 2, 2024
5abcb06
Update MSKFirehoseEventHandler.java
ShashankAWS Jul 3, 2024
f29f105
Update MSKFirehoseEventHandler.java
ShashankAWS Jul 3, 2024
24e1b10
Update MSKFirehoseEventHandlerTest.java
ShashankAWS Jul 3, 2024
feec28f
Update MSKFirehoseEvent.java
ShashankAWS Jul 3, 2024
6fa478e
Update MSKFirehoseResponse.java
ShashankAWS Jul 3, 2024
243253b
Update EventLoader.java
ShashankAWS Jul 3, 2024
4505f6d
Update EventLoaderTest.java
ShashankAWS Jul 3, 2024
cb37072
Update EventLoaderTest.java
ShashankAWS Jul 3, 2024
8239c4a
Update msk_firehose_event.json
ShashankAWS Jul 3, 2024
5769d76
Update EventLoaderTest.java
ShashankAWS Jul 3, 2024
e12da26
Update EventLoaderTest.java
ShashankAWS Jul 9, 2024
6fd7282
Update EventLoaderTest.java
ShashankAWS Jul 9, 2024
4c14fec
Update MSKFirehoseEvent.java
ShashankAWS Jul 9, 2024
b3b5f61
Update MSKFirehoseResponse.java
ShashankAWS Jul 9, 2024
62d58c1
Update MSKFirehoseEventHandler.java
ShashankAWS Jul 10, 2024
641b3f4
Update MSKFirehoseEventHandlerTest.java
ShashankAWS Jul 10, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update MSKFirehoseResponse.java
Expanded the Lombok import, updated java doc for the class and removed the record constructor.
ShashankAWS authored Jul 3, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
commit 6fa478eda52b51b4437a9acb086a1b71bf93cc02
Original file line number Diff line number Diff line change
@@ -3,10 +3,17 @@
import java.nio.ByteBuffer;
import java.util.List;

import lombok.*;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
* Response model for Amazon Data Firehose Lambda transformation with MSK as a source.
msailes marked this conversation as resolved.
Show resolved Hide resolved
* [+] Amazon Data Firehose Data Transformation - Data Transformation and Status Model - <a href="https://docs.aws.amazon.com/firehose/latest/dev/data-transformation.html#data-transformation-status-model">...</a>
* OK : Indicates that processing of this item succeeded.
* ProcessingFailed : Indicate that the processing of this item failed.
* Dropped : Indicates that this item should be silently dropped
*/

@Data
@@ -17,12 +24,12 @@
public class MSKFirehoseResponse {

public enum Result {

/**
msailes marked this conversation as resolved.
Show resolved Hide resolved
* Indicates that processing of this item succeeded.
*/
Ok,

/**
* Indicate that the processing of this item failed
*/
@@ -36,19 +43,14 @@ public enum Result {
public List<Record> records;

@Data
@Builder(setterPrefix = "with")
@NoArgsConstructor
@Builder(setterPrefix = "with")
@AllArgsConstructor

public static class Record {
public String recordId;
public Result result;
public ByteBuffer kafkaRecordValue;

public Record(String recordId, Result result, ByteBuffer kafkaRecordValue) {
super();
this.recordId = recordId;
this.result = result;
this.kafkaRecordValue = kafkaRecordValue;
}
}
}