Kafka Stream: метод преобразования без сохранения состояния - PullRequest
0 голосов
/ 14 мая 2018

Могу ли я использовать преобразование без состояния, даже если это означает изменение ключа на что-то другое?

Примечание: я ограничен методами, соответствующими следующей версии (странице):

https://kafka.apache.org/0101/javadoc/org/apache/kafka/streams/kstream/KStream.html

1 Ответ

0 голосов
/ 14 мая 2018

Да, вы можете использовать transform() без состояния. Обратите внимание, что последний параметр stateStoreNames предназначен для параметров var-args типа String..., который позволяет передавать ноль, одно или несколько имен хранилищ.

Не уверен, что вы подразумеваете под "даже если это означает замену ключа на что-то другое"

...