Bug Report

I am using Kafka Docker. When I stop kafka docker service, whole node application crashes showing NestedError in console.

Environment

• Node version: v8.9.4
• Kafka-node version: ^4.1.3
• Kafka version: wurstmeister/kafka-docker (https://github.com/wurstmeister/kafka-docker)

For specific cases also provide

• Number of Brokers: 1
• Number partitions for topic: 2

Include Sample Code to reproduce behavior

// Refer attached .gif