From 21b4f7907c8514ead404321a9ae806a359ca9640 Mon Sep 17 00:00:00 2001
From: "Sergey A. Kilimnik" <iezious@gmail.com>
Date: Mon, 13 Mar 2017 14:59:45 +0200
Subject: [PATCH] ConsumerGroupOptions & ConsumerGroup fixes

ConsumerGroupOptions & ConsumerGroup fixed according co js code:

ConsumerGroupOptions - added missing fields, optional values marked as optional
ConsumerGroup - fixed class hierarchy, it extends HighLevelConsumer in js code.
---
 kafka-node/index.d.ts | 23 +++++++++++++++++------
 1 file changed, 17 insertions(+), 6 deletions(-)

diff --git a/kafka-node/index.d.ts b/kafka-node/index.d.ts
index a9992ccc52..7523f88c6f 100644
--- a/kafka-node/index.d.ts
+++ b/kafka-node/index.d.ts
@@ -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 {