Если вы не осколите состояние, основываясь на том же ключе, что и входные темы, вы потеряете локальность / совместное разбиение данных, и, таким образом, ваше приложение будет вычислять неверные результаты.
арственные магазины в Kafka Streams создаются внутри страны. Государственные хранилища разделены по ключам, но не позволяют обеспечить разделение, кромепо ключу (насколько мне известно).
ВОПРОСОВ
Какконтролировать количество разделов в государственном магазине внутренне созданной темы? Как раздел хранилища состояний определяет количество разделов и разделов, используемых по умолчанию, и как их переопределить?
Как обойти это, если вы хотите разделить свое хранилище состояний на что-то кроме ключа вашей входящей записи значения ключа и иметь совместное разбиение? В этом случае я бы хотел разделить что-то более конкретное, чем мой обычный ключ. Например. у меня есть
case class RegularKey(fieldA: String)
и я хочу разделить
case class SpecificKey(fieldA: String, fieldB: String)
Для моей темы входящего источника я использую HashPartitioner на количество разделов.