Описание тега node-kafka-streams
Node-Kafka-Streams is a nodejs implementation from nodefluent of Apache Kafka's stream processing library Kafka Streams.
0
ответов
Ошибка подключения к производителю: ошибка: ошибка ssl.certificate.location
Информация об окружающей среде: ОС [например, Mac, Arch, Windows 10]: Windows10 Версия узла [например, 8.2.1]:10.4.1 Версия NPM [например, 5.4.2]:6.4.1 версия node-rdkafka [например, 2.3.3]:2.5.1 Действия по воспроизведению Параметры конфигурации no…
30 янв '19 в 08:09
1
ответ
Что вызывает эту неустойчивую проблему с Node Kafka Streams?
У меня есть производитель и потребитель Кафки. Производитель делает это: const returnMessage = { prop1: 'some string', prop2: 'another string', prop3: nestedObject }; console.log(JSON.stringify(returnMessage)) await stream.writeToStream(JSON.stringi…
31 окт '18 в 07:26
0
ответов
Узел Kafka Streams зависает после первого подключения
У меня есть приложение HTTP2, которое создает нового производителя потоков Kafka и отправляет ему сообщения при получении сообщения из входящего потока. Первый раз он подключается и функционирует нормально. В последующих потоках происходит сбой без …
25 окт '18 в 17:08
2
ответа
Невозможно установить пакет npm (kafka-streams)
Я пытаюсь использовать пакет naf kafka-streams, но получаю ошибку ниже: PS D:\Projects\POCs\kstreams-poc> npm install kafka-streams > node-rdkafka@2.7.1 install D:\Projects\POCs\kstreams-poc\node_modules\node-rdkafka > node-gyp rebuild D:\P…
27 июл '19 в 17:37
0
ответов
Confluent Kafka меняет протокол безопасности с SASL_SSL на SASL_PLAINTEXT
Я использую конфлюэнтное облако для обработки очереди, я уже создал кластер и тему, и все работает нормально. Только я хочу изменить свой протокол безопасности на "SASL_PLAINTEXT", как показано на прикрепленном изображении. Как я могу изменить это с…
01 окт '19 в 23:33
0
ответов
Kafka Streams - Могу ли я использовать один и тот же каталог состояний для нескольких экземпляров потоков с одинаковым идентификатором приложения
У меня есть несколько экземпляров Kafka Streams с одинаковым application.id, которые работают на одном компьютере. Итак, могу ли я использовать один и тот же state.dir для каждого экземпляра или другой state.dir Я где-то читал, что он может заблокир…
16 окт '19 в 09:20
1
ответ
Могут ли kafka-streams прослушивать две темы и ждать другого события, соответствующего идентификатору, и, как только он получит, отправить его в другую тему?
У меня есть две разные темы кафки, в которых есть одинаковый идентификатор поля. Может ли поток прослушивать эти две темы и писать новое сообщение для третьей темы, когда он получает одинаковый идентификатор для обеих этих тем?
30 июл '20 в 06:24
1
ответ
Kafka Streams - несколько потоков или несколько экземпляров с одинаковым идентификатором приложения
У меня есть приложение Kafka Streams, которое использует тему "A" с 10 разделами и около 10 тыс. Сообщений в секунду. Я не понимаю, что будет лучше для моего приложения. To run multiple Kafka Streams application instances with same consumer group. O…
16 окт '19 в 09:13
1
ответ
параллельно пишет разные темы из одной темы потока
У меня есть поток, который дает карту сообщений для двух разных вызовов map(), а затем фильтруется и записывается в две разные темы. KStream<String, byte[]>[] stream = builder.<String, byte[]>stream("source-topic"); stream.map(…
21 авг '20 в 13:08
0
ответов
как решить проблему с ошибкой refreshbrokermetadata в узле?
Проблема ниже при интеграции kafka с узлом после определенного времени запуска приложения на сервере узла. На сервере kafka нет журнала, так как он работает. /app/node_modules/async/dist/async.js:5329 return callback.apply(null, arguments); ^ Nested…
16 май '21 в 12:55
2
ответа
отправка http/2 POST-запроса в Node.js
Как отправить http/2 post-запрос в Node.js? Хочу отправить следующий запрос. curl --http2 "POST" "http://hostname:8088/query-stream" -d $'{"sql": "SELECT * FROM `USERPROFILE` EMIT CHANGES;", "properties": {"ksql.streams.auto.offset.reset": "earliest…
31 май '21 в 16:14
0
ответов
NodeJs — потоки Kafka не выводят сообщения на консоль
Я используюnode-fluent/kafka-streams для подключения к кластеру Kafka, запущенному с помощью . Пример быстрого запуска не выдает никаких сообщений — он показывает только сообщениеstream started, as kafka consumer is ready.. Я могу подтвердить, что с…
10 сен '22 в 06:30
0
ответов
Невозможно установить node-rdkafka. Проблемы с node-gyp
Моему приложению nodejs требуется библиотека kafka-streams. Насколько я знаю, только пакет «kafka-streams» поддерживает потоки kafka, построенные на основе пакета «node-rdkafka». Следовательно, при попытке запустить kafka-streams после успешной уста…
23 окт '23 в 07:54