Результаты поиска по запросу "apache-kafka-streams"
Windows, но я также проверил его на Linux, и он работал.
способ протестировать приложение Kafka Streams. Чтобы я мог определить входные события, а набор тестов показывает мне вывод.Это возможно без реальной настрой...
Каждая запись будет отправлена каждому предикату один раз - это концептуально широковещательная рассылка всем фильтрам, но записи не будут физически реплицированы, поэтому нет никаких накладных расходов памяти.
я есть одна основная тема и несколько предикатов, с каждым из которых связана выходная тема. Я хочу отправить каждую запись во ВСЕ темы, чей предикат разреша...
kafka.apache.org/documentation/streams/...
тоящее время мы реализуем процесс (используя API-интерфейс процессора Kafka), в котором нам нужно объединить информацию из двух взаимосвязанных событий (сообщений) по теме, а затем переслать эту объединенную информацию. События происходят от ...
Да. Похоже, шторм поддерживает скользящее окно на основе счета. Apache Flink также поддерживает это. Хотите знать, почему поток Kafka не поддерживает это.
еализовать агрегацию (или преобразование) скользящего окна с помощью окна с фиксированным размером? Например, если у меня есть потоковые данные, подобные следующим input stream = 1,2,3,4,5,6,7,8...Предположим, что время здесь не имеет ...
Речь шла о фильтрации внутри сервера (брокера), поэтому, когда у вас есть потоки со многими ГБ и низкой избирательностью, большая часть потока не достигает потребителей (приложений). Но KSQL и KStreams являются клиентскими библиотеками == полный поток достигает всех клиентов, и они выполняют фильтрацию.
трю в потоки Кафки. Я хочу отфильтровать свой поток, используя фильтр с очень низкой селективностью (один на несколько тысяч). Я смотрел на этот ...
@quickinsights Я обновил свой ответ, чтобы ответить на ваши вопросы.
тоящее время я пытаюсь легко передавать сообщения из Темы в одном кластере Kafka в другой (Удаленный -> Локальный кластер). Идея состоит в том, чтобы сразу использовать Kafka-Streams, чтобы нам не нужно было реплицировать фактические сообщения на ...
issues.apache.org/jira/browse/KAFKA-4936
ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?
Если вы не осколите состояние, основываясь на том же ключе, что и входные темы, вы потеряете локальность / совместное разбиение данных, и, таким образом, ваше приложение будет вычислять неверные результаты.
арственные магазины в Kafka Streams создаются внутри страны. Государственные хранилища разделены по ключам, но не позволяют обеспечить разделение, кромепо ключу (насколько мне известно). ВОПРОСОВ Какконтролировать количество разделов в ...