@quickinsights Я обновил свой ответ, чтобы ответить на ваши вопросы.

тоящее время я пытаюсь легко передавать сообщения из Темы в одном кластере Kafka в другой (Удаленный -> Локальный кластер). Идея состоит в том, чтобы сразу использовать Kafka-Streams, чтобы нам не нужно было реплицировать фактические сообщения на ...

Если вы не осколите состояние, основываясь на том же ключе, что и входные темы, вы потеряете локальность / совместное разбиение данных, и, таким образом, ваше приложение будет вычислять неверные результаты.

арственные магазины в Kafka Streams создаются внутри страны. Государственные хранилища разделены по ключам, но не позволяют обеспечить разделение, кромепо ключу (насколько мне известно). ВОПРОСОВ Какконтролировать количество разделов в ...

Извините - не уверен, куда это поставить - я не парень из потоков; Я просто взломал ваши материалы, чтобы исключить встроенного брокера (так как это в вашем названии вопроса). Рад попробовать для вас, если вы можете быть более откровенным с тем, что вы хотите, чтобы я сделал. Но это будет завтра; поздно.

хожу в поисках знания тайного. Во-первых, у меня есть две пары тем, по одной теме в каждой паре, которая входит в другую тему. Два KTables формируются последними темами, которые используются в KTable + KTable leftJoin. Проблема в том, что ...

Как зарегистрировать процессор без сохранения состояния (который, кажется, также требует StateStore)?

Распечатать Кафка Стрим Вводить на консоль?

Я просматривал много документации Kafka для Java-приложения, над которым я работаю. Я попытался войти в лямбда-синтаксис, представленный в Java 8, но я немно...

Почему Apache Kafka Streams использует RocksDB и как это можно изменить?

Как добавить пользовательский StateStore к процессору Kafka Streams DSL?

Для одного из моих потоковых приложений Kafka мне нужно использовать функции как DSL, так и Processor API. Мой поток потокового приложения

Как я могу получить значение смещения в KStream

Как отфильтровать ключи и значения с помощью процессора, используя Kafka Stream DSL

У меня есть процессор, который взаимодействует с StateStore для фильтрации и выполнения сложной логики сообщений. в

issues.apache.org/jira/browse/KAFKA-4936

ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?