Basic KafkaService Layer with kafkajs library wrapper
hi mates, I make a very basic KafkaService Layer to wrap the kafkajs library. The code can be found here: https://gist.github.com/khoinguyen/39d2730dd567ccf2f3e397c62830bb1b
When run with ts-node, the program output but stuck there but not finished. The output copied at the end of the gist.
1. I think it should be gracefully finished after it produce the message, and run the
2. The
3.
Any support are appreciated!
When run with ts-node, the program output but stuck there but not finished. The output copied at the end of the gist.
1. I think it should be gracefully finished after it produce the message, and run the
Effect.onExit2. The
onExit runningresult of send3.
NoSuchElementExceptionO.mapselfNoSuchElementExceptionAny support are appreciated!
Similar Threads
Was this page helpful?
