vhad/DefinitelyTyped
1
0
Fork 0
mirror of https://github.com/gosticks/DefinitelyTyped.git synced 2026-10-06 15:57:13 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #15149 from Iezious/patch-1

Browse Source 
ConsumerGroupOptions & ConsumerGroup fixes
This commit is contained in:
Paul van Brenk
2017-03-22 16:20:38 -07:00
committed by GitHub
parent c95e430f4d 21b4f7907c
commit e6905e3d05
1 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kafka-node/index.d.ts
Vendored
+17 -6
View File
@@ -63,7 +63,7 @@ export declare class HighLevelConsumer {
close(force: boolean, cb: () => any): void;
}
export declare class ConsumerGroup {
export declare class ConsumerGroup extends HighLevelConsumer {
constructor(options: ConsumerGroupOptions, topics: string[]);
on(eventName: string, cb: (message: string) => any): void;
on(eventName: string, cb: (error: any) => any): void;
@@ -131,11 +131,22 @@ export interface ConsumerGroupOptions {
ssl?: boolean;
id: string;
groupId: string;
sessionTimeout: number;
protocol: Array<"roundrobin" | "range" | CustomPartitionAssignmentProtocol>;
fromOffset: "earliest" | "latest" | "none";
migrateHLC: false;
migrateRolling: true;
sessionTimeout?: number;
protocol?: Array<"roundrobin" | "range" | CustomPartitionAssignmentProtocol>;
fromOffset?: "earliest" | "latest" | "none";
migrateHLC?: boolean;
migrateRolling?: boolean;
autoCommit?: boolean;
autoCommitIntervalMs?: number;
fetchMaxWaitMs?: number;
paused?: boolean;
maxNumSegments?: number;
fetchMinBytes?: number;
fetchMaxBytes?: number;
retries?: number;
retryFactor?: number;
retryMinTimeout?: number;
connectOnReady?: boolean;
}
export interface Topic {