Fix Auto Interval

Author: opiepj

src/consumer.js

@@ -116,7 +116,7 @@ class Consumer extends KafkaClient {
     this._consumeLoop = setInterval(() => {
       // start consuming messages
       this.kafkaConsumer.consume(this._config.consumeMax);
-    }, this._config.e);
+    }, this._config.throttle);
   }
 
 }

src/index.d.ts

@@ -207,7 +207,7 @@ export class Consumer extends Client {
 
   constructor(conf?: ConsumerConfig, topicConfig?: TopicConfig);
 
-  public onMessage(): Observable<MessagePayload>;
+  public onMessage<Type>(): Observable<MessagePayload<Type>>;
 
   public connect(): Promise<{ name: string }>;