我有一个http2应用程序,它创建了一个新的kafka流生成器,并在接收到来自传入流的消息时向它发送消息。
第一次连接并正常工作。在随后的流中,它失败而不抛出任何类型的错误。
我就是这么做的:
"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););
有人知道什么是错的吗?
暂无答案!
目前还没有任何答案,快来回答吧!