Stream Options

opiepj · opiepj · commit 41d9c4296a60 · 2018-08-29T14:44:19.000-07:00
diff --git a/index.d.ts b/index.d.ts
@@ -26,6 +26,12 @@ export interface ProducerConfig extends Config {
   client?: KafkaProducerConfig;
 }
 
+export interface StreamConfig {
+  objectMode: boolean;
+  topics: string | string[];
+  waitInterval: number;
+}
+
 /**
  * Configuration from rdkafka
  */
