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