diff --git a/events/streams.go b/events/streams.go
new file mode 100644
index 00000000..804b66b7
--- /dev/null
+++ b/events/streams.go
@@ -0,0 +1,31 @@
+package events
+
+// KinesisEventResponse is the outer structure to report batch item failures for KinesisEvent.
+type KinesisEventResponse struct {
+	BatchItemFailures []KinesisBatchItemFailure `json:"batchItemFailures"`
+}
+
+// KinesisBatchItemFailure is the individual record which failed processing.
+type KinesisBatchItemFailure struct {
+	ItemIdentifier string `json:"itemIdentifier"`
+}
+
+// DynamoDBEventResponse is the outer structure to report batch item failures for DynamoDBEvent.
+type DynamoDBEventResponse struct {
+	BatchItemFailures []DynamoDBBatchItemFailure `json:"batchItemFailures"`
+}
+
+// DynamoDBBatchItemFailure is the individual record which failed processing.
+type DynamoDBBatchItemFailure struct {
+	ItemIdentifier string `json:"itemIdentifier"`
+}
+
+// SQSEventResponse is the outer structure to report batch item failures for SQSEvent.
+type SQSEventResponse struct {
+	BatchItemFailures []SQSBatchItemFailure `json:"batchItemFailures"`
+}
+
+// SQSBatchItemFailure is the individual record which failed processing.
+type SQSBatchItemFailure struct {
+	ItemIdentifier string `json:"itemIdentifier"`
+}