Cannot read property 'take' of null on KStream.stream$

[zeeshanalisyed]

I am trying to close the Stream on the given object by calling close function on the instance of class KStream but receiving this error:

Cannot read property 'take' of null on KStream.stream$

I've also debugged that KStream.stream$ contains null value.

kafka-streams/src/lib/dsl/KStream.ts

Line 365 in a9a329a

this.stream$ = this.stream$.take(0);

import { KafkaStreams as Factory, KafkaStreamsConfig, KStream } from "kafka-streams";

interface ZStream extends KStream {
    started: boolean; 
}

let client = new Factory(Config as KafkaStreamsConfig);

let stream = client.getKStream("test");

async function Tester() {
  const started = await stream.start();
  console.log((stream as ZStream).started); // output: true
  const closed = await stream.close()
  console.log((stream as ZStream).started); // output: true which should be false
  const startagain = await stream.start();
  console.log(startagain); // output: Promise.reject => KStream is already started
  const closeagain = await stream.close(); //this part sometimes create problem
}
Tester();

[rob3000]

Hi @zeeshanalisyed thanks for the report. Are you able to provide me with a code sample of what you have so we can replicate it?

[zeeshanalisyed]

Hi @zeeshanalisyed thanks for the report. Are you able to provide me with a code sample of what you have so we can replicate it?

I have added the code above first of all this is produced by using client and stream as a part of the class, stream is not closed at all. but when I use class instance as a wrapper of the stream then that error is produced this is the transformed code from the real code