node.js - 第一次连接后节点 Kafka Streams 挂起
问题描述
我有一个 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););
有没有人知道什么可能是错的?
解决方案
推荐阅读
- c++ - (UE4) 在头部保存一个 lambda 函数
- tfs - TFS 2018 数据仓库 SSRS 报告中的用户名
- javascript - 为 html/javascript 应用程序存储数据
- python - 从 QAbstractListModel 中获取选定项
- android - 如何使用 livedata 进行数据绑定?
- r - R:将函数应用于具有不同长度的嵌套列表
- xcode - 无论哪个分支,react-native 项目都在 xcode 中失败?
- python - 使用 Python smtplib 发送到分发列表
- swift - 为什么我的渐变层比我应用它的 UITextField 小?
- linux - eval `ssh-agent` 和 exec ssh-agent bash 的替代品