diff --git a/types/kafka-node/index.d.ts b/types/kafka-node/index.d.ts
index 89261a3c4d..06464d5602 100644
--- a/types/kafka-node/index.d.ts
+++ b/types/kafka-node/index.d.ts
@@ -6,7 +6,7 @@
 
 // # Classes
 export declare class Client {
-    constructor(connectionString: string, clientId?: string, options?: ZKOptions);
+    constructor(connectionString: string, clientId?: string, options?: ZKOptions, noBatchOptions?: AckBatchOptions, sslOptions?: any);
     close(callback?: Function): void;
     topicExists(topics: Array<string>, callback: Function): void;
     refreshMetadata(topics: Array<string>, cb?: (error: any, data: any) => any): void;
diff --git a/types/kafka-node/kafka-node-tests.ts b/types/kafka-node/kafka-node-tests.ts
index 557c40de8c..a348c8f771 100644
--- a/types/kafka-node/kafka-node-tests.ts
+++ b/types/kafka-node/kafka-node-tests.ts
@@ -6,6 +6,11 @@ var optionsClient = new kafka.Client('localhost:2181/', 'sendMessage', {
     sessionTimeout: 30000,
     spinDelay: 1000,
     retries: 0
+}, {
+  noAckBatchSize: 1000,
+  noAckBatchAge: 1000 * 10
+}, {
+  rejectUnauthorized: false
 });
 optionsClient.close();
 optionsClient.close(function(){});