На рис. 4.14 показано, как выглядит обновленная топология обработки с учетом листинга 4.11. Как вы уже видели, при изменении ключа может потребоваться повторное секционирование данных. Это справедливо и для настоящего примера. Почему же на рисунке нет шага повторного секционирования?
Kafka Streams в действии. Приложения и микросервисы для работы в реальном времени
·
Билл Беджек
