Updated Consumer constructor signature (#10078)

Changed the type of the constructor's `fetchRequests` argument from `Array<Topic>` to `Array<OffsetFetchRequest>`
This commit is contained in:
Logan Aube
2016-07-24 03:32:24 -04:00
committed by Mohamed Hegazy
parent d104e10960
commit 3df355a623

View File

@@ -28,7 +28,7 @@ declare module 'kafka-node' {
}
export class Consumer {
constructor(client: Client, fetchRequests: Array<Topic>, options: ConsumerOptions);
constructor(client: Client, fetchRequests: Array<OffsetFetchRequest>, options: ConsumerOptions);
on(eventName: string, cb: (message: string) => any): void;
on(eventName: string, cb: (error: any) => any): void;
addTopics(topics: Array<string>, cb: (error: any, added: boolean) => any): void;