Результаты поиска по запросу "apache-kafka-streams"
Как обрабатывать ошибки и не фиксировать при использовании Kafka Streams DSL
аюсь разработать потоковую архитектуру для потоковой аналитики. Требования:RT и NRT потоковый ввод данныхПотоковые процессоры, осуществляющие некоторый финан...
issues.apache.org/jira/browse/KAFKA-4936
ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?
Windows, но я также проверил его на Linux, и он работал.
способ протестировать приложение Kafka Streams. Чтобы я мог определить входные события, а набор тестов показывает мне вывод.Это возможно без реальной настрой...
Каждая запись будет отправлена каждому предикату один раз - это концептуально широковещательная рассылка всем фильтрам, но записи не будут физически реплицированы, поэтому нет никаких накладных расходов памяти.
я есть одна основная тема и несколько предикатов, с каждым из которых связана выходная тема. Я хочу отправить каждую запись во ВСЕ темы, чей предикат разреша...
, Обратите внимание, что это всего лишь «запрос к потокам» для фиксации как можно скорее - это не выдача фиксации напрямую.
ли способ сделать коммит вручную с Kafka Stream?Обычно с использованием
использование двух или более кластеров Kafka в приложении Kafka Streams является одним из отличий между Kafka Streams и Spark Structured Streaming (поскольку последний может использовать столько кластеров Kafka, сколько вы хотите, и, таким образом, вы можете строить конвейеры между различными кластерами Kafka) ,
оводство разработчика Kafka Streamsэто говорит: [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] Приложения Kafka Streams могут взаимодействовать только с одним кластером Kafka, указанным в этом значении ...
Речь шла о фильтрации внутри сервера (брокера), поэтому, когда у вас есть потоки со многими ГБ и низкой избирательностью, большая часть потока не достигает потребителей (приложений). Но KSQL и KStreams являются клиентскими библиотеками == полный поток достигает всех клиентов, и они выполняют фильтрацию.
трю в потоки Кафки. Я хочу отфильтровать свой поток, используя фильтр с очень низкой селективностью (один на несколько тысяч). Я смотрел на этот ...
@quickinsights Я обновил свой ответ, чтобы ответить на ваши вопросы.
тоящее время я пытаюсь легко передавать сообщения из Темы в одном кластере Kafka в другой (Удаленный -> Локальный кластер). Идея состоит в том, чтобы сразу использовать Kafka-Streams, чтобы нам не нужно было реплицировать фактические сообщения на ...
Спасибо за исправление! Да, очевидно, что это утверждение вообще неверно. Но верно ли это в предположении, которое я привел в своем ответе: «Предположим, у вас простая топология процессора, без объединений и агрегаций»? Должен ли я добавить слияния тоже?
ичок в Kafka Streams, меня сейчас смущает максимальный параллелизм приложения Kafka Streams. Я прошел по следующей ссылке и не получил ответ, что я ...