Государственный магазин Kafka Streams transform ()

Question

У меня есть сценарий использования, когда мне нужно использовать заголовки в DSL, поэтому используется transformValues ​​(), но не выполняется преобразование с сохранением состояния, а скорее принятие решений на основе заголовков.Мне нужно передать имя хранилища состояний в этой функции. Есть ли альтернатива не давать хранилищу состояний какое-то значение по умолчанию или фиктивное значение?

Answer 1

Мне нужно передать имя хранилища состояний в этой функции

Это не правильно.Подпись KStream#transformValues():

<VR> KStream<K, VR> transformValues(final ValueTransformerSupplier<? super V, ? extends VR> valueTransformerSupplier,
                                    final String... stateStoreNames);

Обратите внимание, что вторым аргументом является var-arg, и вам не нужно предоставлять для него никаких параметров.Следовательно, вы можете вызвать transformValue() с одним аргументом.