Как перейти в StateStore в памяти вместо RocksDB в Spring Cloud Stream

Question

Чтобы сравнить производительность приложения Spring Cloud Stream (с Kafka), использующего RocksDB или в памяти, я бы хотел изменить RocksDB на оперативную память. К сожалению, я не смог найти никакого решения для этого. Я нашел решение для DSL API и для Processor API (https://simplydistributed.wordpress.com/2017/03/21/kafka-streams-state-stores/),, но я не уверен, применимо ли оно для механизма связывания kafka-streams. Может ли кто-нибудь помочь мне в этом вопросе?

С наилучшими пожеланиями Martin

Answer 1

Spring Cloud Stream Binder Kafka Streams не взаимодействует напрямую с RocksDB для каких-либо операций хранилища состояний. Он даже не знает, что общается с RocksDB. Все общение происходит через API и абстракции Kafka Streams. Таким образом, вы можете использовать пользовательские хранилища состояний с потоками Kafka, как предложено в документации, и механизм связывания продолжит работать. Посмотрите, работает ли это, и, пожалуйста, дайте нам знать, если вы обнаружите какие-либо проблемы.