| 1 | import { Handler } from '../handler';
|
| 2 |
|
| 3 | export type MSKHandler = Handler<MSKEvent, void>;
|
| 4 |
|
| 5 | export interface MSKRecordHeader {
|
| 6 | [headerKey: string]: number[];
|
| 7 | }
|
| 8 |
|
| 9 | export interface MSKRecord {
|
| 10 | topic: string;
|
| 11 | partition: number;
|
| 12 | offset: number;
|
| 13 | timestamp: number;
|
| 14 | timestampType: 'CREATE_TIME' | 'LOG_APPEND_TIME';
|
| 15 | key: string;
|
| 16 | value: string;
|
| 17 | headers: MSKRecordHeader[];
|
| 18 | }
|
| 19 |
|
| 20 | export interface MSKEvent {
|
| 21 | eventSource: 'aws:kafka';
|
| 22 | eventSourceArn: string;
|
| 23 | records: {
|
| 24 | [topic: string]: MSKRecord[];
|
| 25 | };
|
| 26 | }
|