Узел Kafka Streams зависает после первого подключения - PullRequest
Новая
       47

Узел Kafka Streams зависает после первого подключения

0 голосов
/ 25 октября 2018

У меня есть приложение 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););

У кого-нибудь есть идеи о том, что может быть не так?

...