title: Node Kafka Streams hangs after first connection
body: <p>I have an HTTP2 application which creates a new Kafka streams producer and sends messages to it on receiving a message from an incoming stream.</p>
  
  <p>The first time it connects and functions properly. On subsequent streams, it fails without throwing any sort of error.</p>
  
  <p>This is how I'm doing it:</p>
  
  <pre><code>"use strict";
  
  const {KafkaStreams} = require('kafka-streams');
  const {nativeConfig: config} = require("./kafka-config.js");
  
  const kafkaStreams = new KafkaStreams(config);
  const stream = kafkaStreams.getKStream(null);
  
  ...stream stuff...
  stream.to("test-topic");
  
  await stream.start()
  
  await stream.writeToStream("my message");
  
  await setTimeout(kafkaStreams.closeAll.bind(kafkaStreams), 100););
  </code></pre>
  
  <p>Does anyone have any ideas of what could be wrong?</p>