Допустим, у нас есть экземпляр с конфигурацией, как указано ниже, и состояния, поддерживаемые в хранилище.
тема - 1
разделы - 6
num.stream.threads - 6
Toplogy
источник - 1
процессоры низкого уровня - 3 (по одному процессору для ежедневной, ежемесячной и годовой агрегации)
приемник - 3
- Какмного параллельных задач возможно с вышеупомянутыми топологическими и тематическими разделами?
В случае, если для ежедневного процессора назначены 2 параллельные задачи, и если пунктуация запланирована для запуска каждые 30 минут, и впереопределение, если мы перенаправим все хранилище в приемник 1, будет ли хранилище значения ключа дважды отправлено в приемник, поскольку 2 параллельные задачи совместно используют одно и то же хранилище ИЛИ каждая задача будет иметь свое собственное хранилище и будет публиковать только данные, соответствующиеразделы, которые им назначены и которые сохраняются в соответствующем хранилище?
KeyValueIterator<String, House> keyValueIterator = houseStore.all();
while (keyValueIterator.hasNext()) {
KeyValue<String, House> next = keyValueIterator.next();
context.forward(next.key, next.value);
}
keyValueIterator.close();
Сколько будет задач, если мы вместо этого будем использовать KTable (по одному для каждой ежедневной, ежемесячной и годовой агрегации) DSL высокого уровня?Могут ли две параллельные задачи обновлять один и тот же KTable (скажем, ежедневно)?